Added gov proposal version.

src/core/env.ts

@@ -1137,7 +1137,10 @@ export const getEnv = ({
     // Call hook.
     await onFetch?.([event])
 
-    return event.value
+    return {
+      ...event.value,
+      version: event.version,
+    }
   }
 
   const getProposals: FormulaProposalsGetter = async () => {
@@ -1199,11 +1202,14 @@ export const getEnv = ({
     // Call hook.
     await onFetch?.(events)
 
-    // Create denom balance map.
+    // Create proposal map.
     return events.reduce(
-      (acc, { proposalId, value }) => ({
+      (acc, { proposalId, value, version }) => ({
         ...acc,
-        [proposalId]: value,
+        [proposalId]: {
+          ...value,
+          version,
+        },
       }),
       {} as Record<string, Record<string, any>>
     )

src/core/types.ts

@@ -482,6 +482,7 @@ export type ParsedGovStateEvent = {
   blockTimeUnixMs: string
   blockTimestamp: Date
   value: Record<string, any>
+  version: string
 }
 
 type RequireAtLeastOne<T, Keys extends keyof T = keyof T> = Pick<

src/db/migrations/20230930091910-alter-bank-state-event-balance-type-bigint-to-string.ts

@@ -1,16 +1,17 @@
 import { QueryInterface } from 'sequelize'
+import { DataType } from 'sequelize-typescript'
 
 module.exports = {
   async up(queryInterface: QueryInterface) {
     await queryInterface.changeColumn('BankStateEvents', 'balance', {
-      type: 'text',
+      type: DataType.TEXT,
       allowNull: false,
     })
   },
 
   async down(queryInterface: QueryInterface) {
     await queryInterface.changeColumn('BankStateEvents', 'balance', {
-      type: 'bigint',
+      type: DataType.BIGINT,
       allowNull: false,
     })
   },

src/db/migrations/20240106235549-add-version-to-gov-state-event.ts

@@ -0,0 +1,16 @@
+import { QueryInterface } from 'sequelize'
+import { DataType } from 'sequelize-typescript'
+
+module.exports = {
+  async up(queryInterface: QueryInterface) {
+    await queryInterface.addColumn('GovStateEvents', 'version', {
+      type: DataType.STRING,
+      allowNull: false,
+      defaultValue: 'v1',
+    })
+  },
+
+  async down(queryInterface: QueryInterface) {
+    await queryInterface.removeColumn('GovStateEvents', 'version')
+  },
+}

src/db/models/GovStateEvent.ts

@@ -47,10 +47,14 @@ export class GovStateEvent extends DependendableEventModel {
   @Column(DataType.DATE)
   blockTimestamp!: Date
 
-  @AllowNull
+  @AllowNull(false)
   @Column(DataType.JSONB)
   value!: any
 
+  @AllowNull(false)
+  @Column(DataType.STRING)
+  version!: string
+
   get block(): Block {
     return {
       height: BigInt(this.blockHeight),

src/scripts/export/handlers/gov.ts

@@ -56,11 +56,14 @@ export const gov: HandlerMaker<ParsedGovStateEvent> = async () => {
 
     // Attempt v1 decoding, falling back to v1beta1. If both fail, ignore.
     let value: any
+    let version
     try {
       value = ProposalV1.toJSON(ProposalV1.decode(valueData))
+      version = 'v1'
     } catch {
       try {
         value = ProposalV1Beta1.toJSON(ProposalV1Beta1.decode(valueData))
+        version = 'v1beta1'
       } catch {
         return
       }
@@ -73,17 +76,19 @@ export const gov: HandlerMaker<ParsedGovStateEvent> = async () => {
       blockTimeUnixMs,
       blockTimestamp,
       value,
+      version,
     }
   }
 
   const process: Handler<ParsedGovStateEvent>['process'] = async (events) => {
     const exportEvents = async () =>
       // Unique index on [blockHeight, proposalId] ensures that we don't insert
       // duplicate events. If we encounter a duplicate, we update the `value`
-      // field in case event processing for a block was batched separately.
+      // and `version` fields in case event processing for a block was batched
+      // separately.
       events.length > 0
         ? await GovStateEvent.bulkCreate(events, {
-            updateOnDuplicate: ['value'],
+            updateOnDuplicate: ['value', 'version'],
           })
         : []