Add tables, emitter, flusher for group module

app/app.go

@@ -536,11 +536,13 @@ func NewBandApp(
 			app.MintKeeper,
 			app.DistrKeeper,
 			app.GovKeeper,
+			app.GroupKeeper,
 			app.OracleKeeper,
 			app.ICAHostKeeper,
 			app.IBCKeeper.ClientKeeper,
 			app.IBCKeeper.ConnectionKeeper,
 			app.IBCKeeper.ChannelKeeper,
+			keys[group.StoreKey],
 			emitterFlag,
 			false,
 		))

flusher/flusher/db.py

@@ -485,6 +485,78 @@ def Column(*args, **kwargs):
     Column("last_update", CustomDateTime, index=True),
 )
 
+
+"""
+This section is mainly for tables of Group module
+"""
+
+groups = sa.Table(
+    "groups",
+    metadata,
+    Column("id", sa.Integer, primary_key=True),
+    Column("version", sa.Integer, index=True),
+    Column("admin", sa.String, sa.ForeignKey("accounts.address")),
+    Column("metadata", sa.String),
+    Column("total_weight", sa.BigInteger),
+    Column("created_at", CustomDateTime),
+)
+
+group_members = sa.Table(
+    "group_members",
+    metadata,
+    Column("group_id", sa.Integer, sa.ForeignKey("groups.id"), primary_key=True),
+    Column("account_id", sa.Integer, sa.ForeignKey("accounts.id"), primary_key=True),
+    Column("weight", sa.BigInteger),
+    Column("metadata", sa.String),
+    Column("added_at", CustomDateTime),
+)
+
+group_policies = sa.Table(
+    "group_policies",
+    metadata,
+    Column("address", sa.String, primary_key=True),
+    Column("type", sa.String),
+    Column("group_id", sa.Integer, sa.ForeignKey("groups.id")),
+    Column("admin", sa.String, sa.ForeignKey("accounts.address")),
+    Column("metadata", sa.String),
+    Column("version", sa.Integer),
+    Column("decision_policy", sa.JSON),
+    Column("created_at", CustomDateTime),
+)
+
+group_proposals = sa.Table(
+    "group_proposals",
+    metadata,
+    Column("id", sa.Integer, primary_key=True),
+    Column("group_policy_address", sa.String, sa.ForeignKey("group_policies.address")),
+    Column("metadata", sa.String),
+    Column("proposers", sa.String),
+    Column("submit_time", CustomDateTime),
+    Column("group_id", sa.Integer, sa.ForeignKey("groups.id")),
+    Column("group_version", sa.Integer, index=True),
+    Column("group_policy_version", sa.Integer, index=True),
+    Column("status", sa.String),
+    Column("yes_vote", sa.BigInteger, nullable=True),
+    Column("no_vote", sa.BigInteger, nullable=True),
+    Column("no_with_veto_vote", sa.BigInteger, nullable=True),
+    Column("abstain_vote", sa.BigInteger, nullable=True),
+    Column("voting_period_end", CustomDateTime),
+    Column("executor_result", sa.String),
+    Column("messages", sa.JSON),
+    Column("title", sa.String),
+    Column("summary", sa.String),
+)
+
+group_votes = sa.Table(
+    "group_votes",
+    metadata,
+    Column("group_proposal_id", sa.Integer, sa.ForeignKey("group_proposals.id"), primary_key=True),
+    Column("voter_id", sa.Integer, sa.ForeignKey("accounts.id"), primary_key=True),
+    Column("option", sa.String),
+    Column("metadata", sa.String),
+    Column("submit_time", CustomDateTime),
+)
+
 relayer_tx_stat_days = sa.Table(
     "relayer_tx_stat_days",
     metadata,

flusher/flusher/handler.py

@@ -38,6 +38,11 @@
     counterparty_chains,
     connections,
     channels,
+    groups,
+    group_members,
+    group_policies,
+    group_proposals,
+    group_votes,
     relayer_tx_stat_days,
 )
 
@@ -85,6 +90,9 @@ def get_data_source_id(self, id):
     def get_oracle_script_id(self, id):
         return self.conn.execute(select([oracle_scripts.c.id]).where(oracle_scripts.c.id == id)).scalar()
 
+    def get_group_id_from_policy_address(self, address):
+        return self.conn.execute(select([group_policies.c.group_id]).where(group_policies.c.address == address)).scalar()
+
     def get_ibc_received_txs(self, date, port, channel, address):
         msg = {"date": date, "port": port, "channel": channel, "address": address}
         condition = True
@@ -140,6 +148,47 @@ def handle_new_data_source(self, msg):
         self.conn.execute(data_sources.insert(), msg)
         self.init_data_source_request_count(msg["id"])
 
+    def handle_new_group(self, msg):
+        self.conn.execute(groups.insert(), msg)
+
+    def handle_new_group_member(self, msg):
+        msg["account_id"] = self.get_account_id(msg["address"])
+        del msg["address"]
+        self.conn.execute(group_members.insert(), msg)
+
+    def handle_new_group_policy(self, msg):
+        self.get_account_id(msg["address"])
+        self.conn.execute(group_policies.insert(), msg)
+
+    def handle_new_group_proposal(self, msg):
+        msg["group_id"] = self.get_group_id_from_policy_address(msg["group_policy_address"])
+        self.conn.execute(group_proposals.insert(), msg)
+
+    def handle_new_group_vote(self, msg):
+        msg["voter_id"] = self.get_account_id(msg["voter_address"])
+        del msg["voter_address"]
+        self.conn.execute(group_votes.insert(), msg)
+
+    def handle_update_group(self, msg):
+        self.conn.execute(groups.update().where(groups.c.id == msg["id"]).values(**msg))
+
+    def handle_remove_group_member(self, msg):
+        account_id = self.get_account_id(msg["address"])
+        self.conn.execute(group_members.delete().where((group_members.c.group_id == msg["group_id"]) & (group_members.c.account_id == account_id)))
+
+    def handle_remove_group_members_by_group_id(self, msg):
+        self.conn.execute(group_members.delete().where(group_members.c.group_id == msg["group_id"]))
+
+    def handle_update_group_policy(self, msg):
+        self.conn.execute(group_policies.update().where(group_policies.c.address == msg["address"]).values(**msg))
+
+    def handle_update_group_proposal(self, msg):
+        msg["group_id"] = self.get_group_id_from_policy_address(msg["group_policy_address"])
+        self.conn.execute(group_proposals.update().where(group_proposals.c.id == msg["id"]).values(**msg))
+
+    def handle_update_group_proposal_by_id(self, msg):
+        self.conn.execute(group_proposals.update().where(group_proposals.c.id == msg["id"]).values(**msg))
+
     def handle_set_data_source(self, msg):
         msg["transaction_id"] = self.get_transaction_id(msg["tx_hash"])
         del msg["tx_hash"]

hasura/hasura-metadata/tables.yaml

@@ -48,6 +48,34 @@
           table:
             name: deposits
             schema: public
+    - name: group_members
+      using:
+        foreign_key_constraint_on:
+          column: account_id
+          table:
+            name: group_members
+            schema: public
+    - name: group_policies
+      using:
+        foreign_key_constraint_on:
+          column: admin
+          table:
+            name: group_policies
+            schema: public
+    - name: group_votes
+      using:
+        foreign_key_constraint_on:
+          column: voter_id
+          table:
+            name: group_votes
+            schema: public
+    - name: groups
+      using:
+        foreign_key_constraint_on:
+          column: admin
+          table:
+            name: groups
+            schema: public
     - name: proposals
       using:
         foreign_key_constraint_on:
@@ -290,6 +318,98 @@
     - name: transaction
       using:
         foreign_key_constraint_on: tx_id
+- table:
+    name: group_members
+    schema: public
+  object_relationships:
+    - name: account
+      using:
+        foreign_key_constraint_on: account_id
+    - name: group
+      using:
+        foreign_key_constraint_on: group_id
+- table:
+    name: group_policies
+    schema: public
+  object_relationships:
+    - name: account
+      using:
+        foreign_key_constraint_on: admin
+    - name: group
+      using:
+        foreign_key_constraint_on: group_id
+  array_relationships:
+    - name: group_proposals
+      using:
+        foreign_key_constraint_on:
+          column: group_policy_address
+          table:
+            name: group_proposals
+            schema: public
+- table:
+    name: group_proposals
+    schema: public
+  object_relationships:
+    - name: group
+      using:
+        foreign_key_constraint_on: group_id
+    - name: group_policy
+      using:
+        foreign_key_constraint_on: group_policy_address
+    - name: group_vote
+      using:
+        foreign_key_constraint_on:
+          column: group_proposal_id
+          table:
+            name: group_votes
+            schema: public
+  array_relationships:
+    - name: group_votes
+      using:
+        foreign_key_constraint_on:
+          column: group_proposal_id
+          table:
+            name: group_votes
+            schema: public
+- table:
+    name: group_votes
+    schema: public
+  object_relationships:
+    - name: account
+      using:
+        foreign_key_constraint_on: voter_id
+    - name: group_proposal
+      using:
+        foreign_key_constraint_on: group_proposal_id
+- table:
+    name: groups
+    schema: public
+  object_relationships:
+    - name: account
+      using:
+        foreign_key_constraint_on: admin
+  array_relationships:
+    - name: group_members
+      using:
+        foreign_key_constraint_on:
+          column: group_id
+          table:
+            name: group_members
+            schema: public
+    - name: group_policies
+      using:
+        foreign_key_constraint_on:
+          column: group_id
+          table:
+            name: group_policies
+            schema: public
+    - name: group_proposals
+      using:
+        foreign_key_constraint_on:
+          column: group_id
+          table:
+            name: group_proposals
+            schema: public
 - table:
     name: historical_bonded_token_on_validators
     schema: public