add chainalysis

.dockerignore

@@ -128,3 +128,4 @@ dist
 .yarn/build-state.yml
 .yarn/install-state.gz
 .pnp.*
+secrets

.github/workflows/ci.yml

@@ -10,3 +10,4 @@ jobs:
           node-version: node
       - run: npm ci
       - run: npm test
+      - run: CHAINALYSIS_API_KEY=${{ secrets.CHAINALYSIS_API_KEY }} npm run test:integration

.gitignore

@@ -128,3 +128,4 @@ dist
 .yarn/build-state.yml
 .yarn/install-state.gz
 .pnp.*
+secrets

.npmignore

@@ -0,0 +1 @@
+secrets

Dockerfile

@@ -12,7 +12,6 @@ WORKDIR /app
 # Set production environment
 ENV NODE_ENV="production"
 
-
 # Throw-away build stage to reduce size of final image
 FROM base as build
 

bin/station-wallet-screening.js

@@ -1,10 +1,17 @@
 import http from 'node:http'
 import { once } from 'node:events'
-import { handler } from '../index.js'
+import { createHandler } from '../index.js'
+import assert from 'node:assert'
 
-const { PORT = 3000 } = process.env
+const {
+  PORT = 3000,
+  CHAINALYSIS_API_KEY
+} = process.env
+assert(CHAINALYSIS_API_KEY)
 
-const server = http.createServer(handler)
+const server = http.createServer(createHandler({
+  apiKey: CHAINALYSIS_API_KEY
+}))
 server.listen(PORT)
 await once(server, 'listening')
 console.log(`http://127.0.0.1:${PORT}`)

fly.toml

@@ -15,3 +15,6 @@ primary_region = "cdg"
   auto_start_machines = true
   min_machines_running = 0
   processes = ["app"]
+
+[[http_service.checks]]
+  path = "/0x000000000000000000000000000000000000dEaD"

index.js

@@ -1,11 +1,31 @@
 import { STATUS_CODES } from 'node:http'
+import assert from 'node:assert'
 
-const forbiddenAddresses = new Set([
-  '0xFORBIDDEN'
-])
-
-export const handler = (req, res) => {
+const handler = async (req, res, apiKey, fetch, log) => {
   const address = req.url.split('/')[1].trim()
-  res.statusCode = forbiddenAddresses.has(address) ? 403 : 200
+  const fetchRes = await fetch(
+    `https://public.chainalysis.com/api/v1/address/${address}`,
+    {
+      headers: {
+        'X-API-Key': apiKey,
+        accept: 'application/json'
+      }
+    }
+  )
+  assert(fetchRes.ok, `Chainalysis API status ${fetchRes.status}`)
+  const body = await fetchRes.json()
+  res.statusCode = body.identifications.length > 0 ? 403 : 200
   res.end(STATUS_CODES[res.statusCode])
 }
+
+export const createHandler = ({
+  apiKey,
+  fetch = globalThis.fetch,
+  log = console.log
+}) => (req, res) => {
+  handler(req, res, apiKey, fetch, log).catch(err => {
+    log(err)
+    res.statusCode = 500
+    res.end('Internal Server Error')
+  })
+}