added telegram notifier webhook

config.json.example

@@ -40,6 +40,7 @@
  },
  "daoDaoBase": "https://testnet.daodao.zone",
  "discordNotifierApiKey": "key",
+ "telegramNotifierApiKey": "key",
  "inboxSecret": "secret",
  "notifierSecret": "secret",
  "websocketsSecret": "secret",

src/webhooks/webhooks/index.ts

@@ -4,9 +4,10 @@ import { State, WasmStateEvent } from '@/db'
 import { WasmCodeService } from '@/services/wasm-codes'
 import { Config, ProcessedWebhook, Webhook, WebhookMaker } from '@/types'
 
-import * as discordNotifier from './discordNotifier'
+import * as discord from './discord'
 import * as indexerCwReceipt from './indexerCwReceipt'
 import * as notify from './notify'
+import * as telegram from './telegram'
 import * as websockets from './websockets'
 
 let processedWebhooks: ProcessedWebhook<any, any>[] | undefined
@@ -17,7 +18,8 @@ export const getProcessedWebhooks = (
  if (!processedWebhooks) {
  const webhookMakers: WebhookMaker<any, any>[] = [
  // Add webhook makers here.
- ...Object.values(discordNotifier),
+ ...Object.values(discord),
+ ...Object.values(telegram),
  ...Object.values(indexerCwReceipt),
  ...Object.values(notify),
  ...Object.values(websockets),

src/webhooks/webhooks/telegram.ts

@@ -0,0 +1,92 @@
+import { WasmStateEvent } from '@/db'
+import {
+ activeProposalModules,
+ config as daoCoreConfig,
+} from '@/formulas/formulas/contract/daoCore/base'
+import { StatusEnum } from '@/formulas/formulas/contract/proposal/types'
+import { WebhookMaker, WebhookType } from '@/types'
+import { dbKeyForKeys, dbKeyToKeys } from '@/utils'
+
+import { getDaoAddressForProposalModule } from '../utils'
+
+const CODE_IDS_KEYS = ['dao-proposal-single', 'dao-proposal-multiple']
+
+const KEY_PREFIX_PROPOSALS = dbKeyForKeys('proposals', '')
+const KEY_PREFIX_PROPOSALS_V2 = dbKeyForKeys('proposals_v2', '')
+
+// Fire webhook when a proposal is created.
+export const makeProposalCreated: WebhookMaker<WasmStateEvent> = (
+ config,
+ state
+) => ({
+ filter: {
+ EventType: WasmStateEvent,
+ codeIdsKeys: CODE_IDS_KEYS,
+ matches: (event) =>
+ // Starts with proposals or proposals_v2.
+ (event.key.startsWith(KEY_PREFIX_PROPOSALS) ||
+ event.key.startsWith(KEY_PREFIX_PROPOSALS_V2)) &&
+ event.valueJson.status === StatusEnum.Open,
+ },
+ endpoint: async (event, env) => {
+ const daoAddress = await getDaoAddressForProposalModule({
+ ...env,
+ contractAddress: event.contractAddress,
+ })
+ if (!daoAddress) {
+ return
+ }
+
+ return {
+ type: WebhookType.Url,
+ url: `https://telegram-notifier.dao-dao.workers.dev/${state.chainId}/${daoAddress}/notify`,
+ method: 'POST',
+ }
+ },
+ getValue: async (event, getLastEvent, env) => {
+ // Only fire the webhook the first time this exists.
+ if ((await getLastEvent()) !== null) {
+ return
+ }
+
+ // Get DAO config and proposal modules for this DAO so we can retrieve the
+ // DAO's name and the prefix for this proposal module.
+ const daoAddress = await getDaoAddressForProposalModule({
+ ...env,
+ contractAddress: event.contractAddress,
+ })
+ if (!daoAddress) {
+ return
+ }
+
+ const daoConfig = await daoCoreConfig.compute({
+ ...env,
+ contractAddress: daoAddress,
+ })
+ const proposalModules = await activeProposalModules.compute({
+ ...env,
+ contractAddress: daoAddress,
+ })
+ const proposalModule = proposalModules?.find(
+ (proposalModule) => proposalModule.address === event.contractAddress
+ )
+
+ if (!daoConfig || !proposalModule) {
+ return
+ }
+
+ // "proposals"|"proposals_v2", proposalNum
+ const [, proposalNum] = dbKeyToKeys(event.key, [false, true])
+ const proposalId = `${proposalModule.prefix}${proposalNum}`
+
+ return {
+ apiKey: config.telegramNotifierApiKey,
+ data: {
+ content:
+ `🎉 ${daoConfig.name} — Proposal ${proposalId} 🎉\n` +
+ config.daoDaoBase +
+ `/dao/${daoAddress}/proposals/${proposalId}`,
+ },
+ }
+ },
+})