feat: Add analytics endpoints to fetch identity data [DEV-4774] (#269)

* feat: Add analytics endpoints to fetch identity data

* fix: Resolve testnet cronjob failures [DEV-4789] (#270)

fix: Resolve testnet cronjob failures

* package bump

* Apply DB changes and format API responses differently

* bump

* Remove ledgerDenom and ledgerOperationType from response & fix typo in DB schema

* Allow case-insensitive filtering

---------

Co-authored-by: Ankur Banerjee <ankurdotb@users.noreply.github.com>

Author: filipdjokic

package-lock.json

@@ -20,11 +20,11 @@
   "dependencies": {
     "drizzle-orm": "^0.40.0",
     "itty-router": "^3.0.12",
-    "pg": "^8.13.3"
+    "pg": "^8.14.0"
   },
   "devDependencies": {
-    "@cloudflare/workers-types": "^4.20250303.0",
-    "@types/node": "^20.17.23",
+    "@cloudflare/workers-types": "^4.20250311.0",
+    "@types/node": "^20.17.24",
     "@types/pg": "^8.11.11",
     "@typescript-eslint/eslint-plugin": "^7.18.0",
     "@typescript-eslint/parser": "^7.18.0",
@@ -34,7 +34,7 @@
     "eslint-config-typescript": "^3.0.0",
     "prettier": "^3.5.3",
     "typescript": "^5.8.2",
-    "wrangler": "^3.113.0"
+    "wrangler": "^3.114.1"
   },
   "engines": {
     "node": ">=20.0.0"

package.json

@@ -1,10 +1,12 @@
 import { Client } from 'pg';
-import { drizzle } from 'drizzle-orm/node-postgres';
+import { drizzle, NodePgDatabase } from 'drizzle-orm/node-postgres';
 import * as schema from './schema';
 
 // Default timeout for PostgreSQL queries (30 seconds)
 const DEFAULT_POSTGRES_TIMEOUT = 30000;
 
+export type DrizzleClient = NodePgDatabase<typeof schema>;
+
 export async function dbInit(env?: any): Promise<{ db: any; client: Client }> {
 	try {
 		// Create a single PostgreSQL client

src/database/client.ts

@@ -0,0 +1,16 @@
+ALTER TABLE "operation_types_mainnet" RENAME COLUMN "type" TO "ledger_operation_type";--> statement-breakpoint
+ALTER TABLE "operation_types_testnet" RENAME COLUMN "type" TO "ledger_operation_type";--> statement-breakpoint
+ALTER TABLE "operation_types_mainnet" DROP CONSTRAINT "operation_types_mainnet_type_unique";--> statement-breakpoint
+ALTER TABLE "operation_types_testnet" DROP CONSTRAINT "operation_types_testnet_type_unique";--> statement-breakpoint
+ALTER TABLE "denom_mainnet" ALTER COLUMN "ledger_denom" SET DATA TYPE denoms_enum_mainnet;--> statement-breakpoint
+ALTER TABLE "denom_mainnet" ALTER COLUMN "ledger_denom" SET DEFAULT 'ncheq';--> statement-breakpoint
+ALTER TABLE "denom_mainnet" ALTER COLUMN "friendly_denom" SET DATA TYPE varchar;--> statement-breakpoint
+ALTER TABLE "denom_mainnet" ALTER COLUMN "friendly_denom" SET DEFAULT 'CHEQ';--> statement-breakpoint
+ALTER TABLE "denom_testnet" ALTER COLUMN "ledger_denom" SET DATA TYPE denoms_enum_testnet;--> statement-breakpoint
+ALTER TABLE "denom_testnet" ALTER COLUMN "ledger_denom" SET DEFAULT 'ncheq';--> statement-breakpoint
+ALTER TABLE "denom_testnet" ALTER COLUMN "friendly_denom" SET DATA TYPE varchar;--> statement-breakpoint
+ALTER TABLE "denom_testnet" ALTER COLUMN "friendly_denom" SET DEFAULT 'ncheq';--> statement-breakpoint
+ALTER TABLE "operation_types_mainnet" ADD COLUMN "friendly_operation_type" varchar DEFAULT 'friendly' NOT NULL;--> statement-breakpoint
+ALTER TABLE "operation_types_testnet" ADD COLUMN "friendly_operation_type" varchar DEFAULT 'friendly' NOT NULL;--> statement-breakpoint
+ALTER TABLE "operation_types_mainnet" ADD CONSTRAINT "operation_types_mainnet_ledger_operation_type_unique" UNIQUE("ledger_operation_type");--> statement-breakpoint
+ALTER TABLE "operation_types_testnet" ADD CONSTRAINT "operation_types_testnet_ledger_operation_type_unique" UNIQUE("ledger_operation_type");

src/database/migrations/0002_dazzling_colossus.sql

@@ -0,0 +1,6 @@
+ALTER TABLE "did_mainnet" RENAME COLUMN "operationType" TO "operation_type";--> statement-breakpoint
+ALTER TABLE "did_mainnet" DROP CONSTRAINT "did_mainnet_operationType_operation_types_mainnet_id_fk";
+--> statement-breakpoint
+DROP INDEX "idx_did_mainnet_tx_op_did";--> statement-breakpoint
+ALTER TABLE "did_mainnet" ADD CONSTRAINT "did_mainnet_operation_type_operation_types_mainnet_id_fk" FOREIGN KEY ("operation_type") REFERENCES "public"."operation_types_mainnet"("id") ON DELETE no action ON UPDATE no action;--> statement-breakpoint
+CREATE INDEX "idx_did_mainnet_tx_op_did" ON "did_mainnet" USING btree ("transaction_hash","operation_type","did_id");