commit 6ba8a3e7b9a8f2da3e4ec7e5321390dd6dd30618 · keays.io/feed-generator-go

+90

go.mod

···

       1
       +
       module banana.com

     

       2
       +
       

     

       3
       +
       go 1.23.0

     

       4
       +
       

     

       5
       +
       toolchain go1.23.9

     

       6
       +
       

     

       7
       +
       require (

     

       8
       +
       	github.com/bluesky-social/indigo v0.0.0-20250520232546-236dd575c91e

     

       9
       +
       	github.com/fxamacker/cbor/v2 v2.8.0

     

       10
       +
       	github.com/go-chi/chi/v5 v5.2.1

     

       11
       +
       	github.com/gorilla/websocket v1.5.3

     

       12
       +
       	github.com/ipfs/go-cid v0.4.1

     

       13
       +
       	modernc.org/sqlite v1.37.1

     

       14
       +
       )

     

       15
       +
       

     

       16
       +
       require (

     

       17
       +
       	github.com/beorn7/perks v1.0.1 // indirect

     

       18
       +
       	github.com/carlmjohnson/versioninfo v0.22.5 // indirect

     

       19
       +
       	github.com/cespare/xxhash/v2 v2.2.0 // indirect

     

       20
       +
       	github.com/dustin/go-humanize v1.0.1 // indirect

     

       21
       +
       	github.com/felixge/httpsnoop v1.0.4 // indirect

     

       22
       +
       	github.com/go-logr/logr v1.4.1 // indirect

     

       23
       +
       	github.com/go-logr/stdr v1.2.2 // indirect

     

       24
       +
       	github.com/gogo/protobuf v1.3.2 // indirect

     

       25
       +
       	github.com/google/uuid v1.6.0 // indirect

     

       26
       +
       	github.com/hashicorp/go-cleanhttp v0.5.2 // indirect

     

       27
       +
       	github.com/hashicorp/go-retryablehttp v0.7.5 // indirect

     

       28
       +
       	github.com/hashicorp/golang-lru v1.0.2 // indirect

     

       29
       +
       	github.com/hashicorp/golang-lru/v2 v2.0.7 // indirect

     

       30
       +
       	github.com/ipfs/bbloom v0.0.4 // indirect

     

       31
       +
       	github.com/ipfs/go-block-format v0.2.0 // indirect

     

       32
       +
       	github.com/ipfs/go-blockservice v0.5.2 // indirect

     

       33
       +
       	github.com/ipfs/go-datastore v0.6.0 // indirect

     

       34
       +
       	github.com/ipfs/go-ipfs-blockstore v1.3.1 // indirect

     

       35
       +
       	github.com/ipfs/go-ipfs-ds-help v1.1.1 // indirect

     

       36
       +
       	github.com/ipfs/go-ipfs-exchange-interface v0.2.1 // indirect

     

       37
       +
       	github.com/ipfs/go-ipfs-util v0.0.3 // indirect

     

       38
       +
       	github.com/ipfs/go-ipld-cbor v0.1.0 // indirect

     

       39
       +
       	github.com/ipfs/go-ipld-format v0.6.0 // indirect

     

       40
       +
       	github.com/ipfs/go-ipld-legacy v0.2.1 // indirect

     

       41
       +
       	github.com/ipfs/go-log v1.0.5 // indirect

     

       42
       +
       	github.com/ipfs/go-log/v2 v2.5.1 // indirect

     

       43
       +
       	github.com/ipfs/go-merkledag v0.11.0 // indirect

     

       44
       +
       	github.com/ipfs/go-metrics-interface v0.0.1 // indirect

     

       45
       +
       	github.com/ipfs/go-verifcid v0.0.3 // indirect

     

       46
       +
       	github.com/ipld/go-car v0.6.1-0.20230509095817-92d28eb23ba4 // indirect

     

       47
       +
       	github.com/ipld/go-codec-dagpb v1.6.0 // indirect

     

       48
       +
       	github.com/ipld/go-ipld-prime v0.21.0 // indirect

     

       49
       +
       	github.com/jbenet/goprocess v0.1.4 // indirect

     

       50
       +
       	github.com/klauspost/cpuid/v2 v2.2.7 // indirect

     

       51
       +
       	github.com/mattn/go-isatty v0.0.20 // indirect

     

       52
       +
       	github.com/matttproud/golang_protobuf_extensions/v2 v2.0.0 // indirect

     

       53
       +
       	github.com/minio/sha256-simd v1.0.1 // indirect

     

       54
       +
       	github.com/mr-tron/base58 v1.2.0 // indirect

     

       55
       +
       	github.com/multiformats/go-base32 v0.1.0 // indirect

     

       56
       +
       	github.com/multiformats/go-base36 v0.2.0 // indirect

     

       57
       +
       	github.com/multiformats/go-multibase v0.2.0 // indirect

     

       58
       +
       	github.com/multiformats/go-multihash v0.2.3 // indirect

     

       59
       +
       	github.com/multiformats/go-varint v0.0.7 // indirect

     

       60
       +
       	github.com/ncruces/go-strftime v0.1.9 // indirect

     

       61
       +
       	github.com/opentracing/opentracing-go v1.2.0 // indirect

     

       62
       +
       	github.com/polydawn/refmt v0.89.1-0.20221221234430-40501e09de1f // indirect

     

       63
       +
       	github.com/prometheus/client_golang v1.17.0 // indirect

     

       64
       +
       	github.com/prometheus/client_model v0.5.0 // indirect

     

       65
       +
       	github.com/prometheus/common v0.45.0 // indirect

     

       66
       +
       	github.com/prometheus/procfs v0.12.0 // indirect

     

       67
       +
       	github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec // indirect

     

       68
       +
       	github.com/spaolacci/murmur3 v1.1.0 // indirect

     

       69
       +
       	github.com/whyrusleeping/cbor-gen v0.2.1-0.20241030202151-b7a6831be65e // indirect

     

       70
       +
       	github.com/x448/float16 v0.8.4 // indirect

     

       71
       +
       	gitlab.com/yawning/secp256k1-voi v0.0.0-20230925100816-f2616030848b // indirect

     

       72
       +
       	gitlab.com/yawning/tuplehash v0.0.0-20230713102510-df83abbf9a02 // indirect

     

       73
       +
       	go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.46.1 // indirect

     

       74
       +
       	go.opentelemetry.io/otel v1.21.0 // indirect

     

       75
       +
       	go.opentelemetry.io/otel/metric v1.21.0 // indirect

     

       76
       +
       	go.opentelemetry.io/otel/trace v1.21.0 // indirect

     

       77
       +
       	go.uber.org/atomic v1.11.0 // indirect

     

       78
       +
       	go.uber.org/multierr v1.11.0 // indirect

     

       79
       +
       	go.uber.org/zap v1.26.0 // indirect

     

       80
       +
       	golang.org/x/crypto v0.21.0 // indirect

     

       81
       +
       	golang.org/x/exp v0.0.0-20250408133849-7e4ce0ab07d0 // indirect

     

       82
       +
       	golang.org/x/sys v0.33.0 // indirect

     

       83
       +
       	golang.org/x/time v0.3.0 // indirect

     

       84
       +
       	golang.org/x/xerrors v0.0.0-20231012003039-104605ab7028 // indirect

     

       85
       +
       	google.golang.org/protobuf v1.33.0 // indirect

     

       86
       +
       	lukechampine.com/blake3 v1.2.1 // indirect

     

       87
       +
       	modernc.org/libc v1.65.7 // indirect

     

       88
       +
       	modernc.org/mathutil v1.7.1 // indirect

     

       89
       +
       	modernc.org/memory v1.11.0 // indirect

     

       90
       +
       )

+383

go.sum

···

       1
       +
       github.com/BurntSushi/toml v0.3.1/go.mod h1:xHWCNGjB5oqiDr8zfno3MHue2Ht5sIBksp03qcyfWMU=

     

       2
       +
       github.com/benbjohnson/clock v1.1.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA=

     

       3
       +
       github.com/benbjohnson/clock v1.3.0 h1:ip6w0uFQkncKQ979AypyG0ER7mqUSBdKLOgAle/AT8A=

     

       4
       +
       github.com/benbjohnson/clock v1.3.0/go.mod h1:J11/hYXuz8f4ySSvYwY0FKfm+ezbsZBKZxNJlLklBHA=

     

       5
       +
       github.com/beorn7/perks v1.0.1 h1:VlbKKnNfV8bJzeqoa4cOKqO6bYr3WgKZxO8Z16+hsOM=

     

       6
       +
       github.com/beorn7/perks v1.0.1/go.mod h1:G2ZrVWU2WbWT9wwq4/hrbKbnv/1ERSJQ0ibhJ6rlkpw=

     

       7
       +
       github.com/bluesky-social/indigo v0.0.0-20250520232546-236dd575c91e h1:DVD+HxQsDCVJtAkjfIKZVaBNc3kayHaU+A2TJZkFdp4=

     

       8
       +
       github.com/bluesky-social/indigo v0.0.0-20250520232546-236dd575c91e/go.mod h1:ovyxp8AMO1Hoe838vMJUbqHTZaAR8ABM3g3TXu+A5Ng=

     

       9
       +
       github.com/carlmjohnson/versioninfo v0.22.5 h1:O00sjOLUAFxYQjlN/bzYTuZiS0y6fWDQjMRvwtKgwwc=

     

       10
       +
       github.com/carlmjohnson/versioninfo v0.22.5/go.mod h1:QT9mph3wcVfISUKd0i9sZfVrPviHuSF+cUtLjm2WSf8=

     

       11
       +
       github.com/cespare/xxhash/v2 v2.2.0 h1:DC2CZ1Ep5Y4k3ZQ899DldepgrayRUGE6BBZ/cd9Cj44=

     

       12
       +
       github.com/cespare/xxhash/v2 v2.2.0/go.mod h1:VGX0DQ3Q6kWi7AoAeZDth3/j3BFtOZR5XLFGgcrjCOs=

     

       13
       +
       github.com/cpuguy83/go-md2man/v2 v2.0.0-20190314233015-f79a8a8ca69d/go.mod h1:maD7wRr/U5Z6m/iR4s+kqSMx2CaBsrgA7czyZG/E6dU=

     

       14
       +
       github.com/cskr/pubsub v1.0.2 h1:vlOzMhl6PFn60gRlTQQsIfVwaPB/B/8MziK8FhEPt/0=

     

       15
       +
       github.com/cskr/pubsub v1.0.2/go.mod h1:/8MzYXk/NJAz782G8RPkFzXTZVu63VotefPnR9TIRis=

     

       16
       +
       github.com/davecgh/go-spew v1.1.0/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=

     

       17
       +
       github.com/davecgh/go-spew v1.1.1 h1:vj9j/u1bqnvCEfJOwUhtlOARqs3+rkHYY13jYWTU97c=

     

       18
       +
       github.com/davecgh/go-spew v1.1.1/go.mod h1:J7Y8YcW2NihsgmVo/mv3lAwl/skON4iLHjSsI+c5H38=

     

       19
       +
       github.com/decred/dcrd/dcrec/secp256k1/v4 v4.2.0 h1:8UrgZ3GkP4i/CLijOJx79Yu+etlyjdBU4sfcs2WYQMs=

     

       20
       +
       github.com/decred/dcrd/dcrec/secp256k1/v4 v4.2.0/go.mod h1:v57UDF4pDQJcEfFUCRop3lJL149eHGSe9Jvczhzjo/0=

     

       21
       +
       github.com/dustin/go-humanize v1.0.1 h1:GzkhY7T5VNhEkwH0PVJgjz+fX1rhBrR7pRT3mDkpeCY=

     

       22
       +
       github.com/dustin/go-humanize v1.0.1/go.mod h1:Mu1zIs6XwVuF/gI1OepvI0qD18qycQx+mFykh5fBlto=

     

       23
       +
       github.com/felixge/httpsnoop v1.0.4 h1:NFTV2Zj1bL4mc9sqWACXbQFVBBg2W3GPvqp8/ESS2Wg=

     

       24
       +
       github.com/felixge/httpsnoop v1.0.4/go.mod h1:m8KPJKqk1gH5J9DgRY2ASl2lWCfGKXixSwevea8zH2U=

     

       25
       +
       github.com/frankban/quicktest v1.14.6 h1:7Xjx+VpznH+oBnejlPUj8oUpdxnVs4f8XU8WnHkI4W8=

     

       26
       +
       github.com/frankban/quicktest v1.14.6/go.mod h1:4ptaffx2x8+WTWXmUCuVU6aPUX1/Mz7zb5vbUoiM6w0=

     

       27
       +
       github.com/fxamacker/cbor/v2 v2.8.0 h1:fFtUGXUzXPHTIUdne5+zzMPTfffl3RD5qYnkY40vtxU=

     

       28
       +
       github.com/fxamacker/cbor/v2 v2.8.0/go.mod h1:vM4b+DJCtHn+zz7h3FFp/hDAI9WNWCsZj23V5ytsSxQ=

     

       29
       +
       github.com/go-chi/chi/v5 v5.2.1 h1:KOIHODQj58PmL80G2Eak4WdvUzjSJSm0vG72crDCqb8=

     

       30
       +
       github.com/go-chi/chi/v5 v5.2.1/go.mod h1:L2yAIGWB3H+phAw1NxKwWM+7eUH/lU8pOMm5hHcoops=

     

       31
       +
       github.com/go-logr/logr v1.2.2/go.mod h1:jdQByPbusPIv2/zmleS9BjJVeZ6kBagPoEUsqbVz/1A=

     

       32
       +
       github.com/go-logr/logr v1.4.1 h1:pKouT5E8xu9zeFC39JXRDukb6JFQPXM5p5I91188VAQ=

     

       33
       +
       github.com/go-logr/logr v1.4.1/go.mod h1:9T104GzyrTigFIr8wt5mBrctHMim0Nb2HLGrmQ40KvY=

     

       34
       +
       github.com/go-logr/stdr v1.2.2 h1:hSWxHoqTgW2S2qGc0LTAI563KZ5YKYRhT3MFKZMbjag=

     

       35
       +
       github.com/go-logr/stdr v1.2.2/go.mod h1:mMo/vtBO5dYbehREoey6XUKy/eSumjCCveDpRre4VKE=

     

       36
       +
       github.com/go-yaml/yaml v2.1.0+incompatible/go.mod h1:w2MrLa16VYP0jy6N7M5kHaCkaLENm+P+Tv+MfurjSw0=

     

       37
       +
       github.com/gogo/protobuf v1.3.2 h1:Ov1cvc58UF3b5XjBnZv7+opcTcQFZebYjWzi34vdm4Q=

     

       38
       +
       github.com/gogo/protobuf v1.3.2/go.mod h1:P1XiOD3dCwIKUDQYPy72D8LYyHL2YPYrpS2s69NZV8Q=

     

       39
       +
       github.com/google/go-cmp v0.6.0 h1:ofyhxvXcZhMsU5ulbFiLKl/XBFqE1GSq7atu8tAmTRI=

     

       40
       +
       github.com/google/go-cmp v0.6.0/go.mod h1:17dUlkBOakJ0+DkrSSNjCkIjxS6bF9zb3elmeNGIjoY=

     

       41
       +
       github.com/google/gopacket v1.1.19 h1:ves8RnFZPGiFnTS0uPQStjwru6uO6h+nlr9j6fL7kF8=

     

       42
       +
       github.com/google/gopacket v1.1.19/go.mod h1:iJ8V8n6KS+z2U1A8pUwu8bW5SyEMkXJB8Yo/Vo+TKTo=

     

       43
       +
       github.com/google/pprof v0.0.0-20250317173921-a4b03ec1a45e h1:ijClszYn+mADRFY17kjQEVQ1XRhq2/JR1M3sGqeJoxs=

     

       44
       +
       github.com/google/pprof v0.0.0-20250317173921-a4b03ec1a45e/go.mod h1:boTsfXsheKC2y+lKOCMpSfarhxDeIzfZG1jqGcPl3cA=

     

       45
       +
       github.com/google/renameio v0.1.0/go.mod h1:KWCgfxg9yswjAJkECMjeO8J8rahYeXnNhOm40UhjYkI=

     

       46
       +
       github.com/google/uuid v1.6.0 h1:NIvaJDMOsjHA8n1jAhLSgzrAzy1Hgr+hNrb57e+94F0=

     

       47
       +
       github.com/google/uuid v1.6.0/go.mod h1:TIyPZe4MgqvfeYDBFedMoGGpEw/LqOeaOT+nhxU+yHo=

     

       48
       +
       github.com/gopherjs/gopherjs v0.0.0-20181017120253-0766667cb4d1 h1:EGx4pi6eqNxGaHF6qqu48+N2wcFQ5qg5FXgOdqsJ5d8=

     

       49
       +
       github.com/gopherjs/gopherjs v0.0.0-20181017120253-0766667cb4d1/go.mod h1:wJfORRmW1u3UXTncJ5qlYoELFm8eSnnEO6hX4iZ3EWY=

     

       50
       +
       github.com/gorilla/websocket v1.5.3 h1:saDtZ6Pbx/0u+bgYQ3q96pZgCzfhKXGPqt7kZ72aNNg=

     

       51
       +
       github.com/gorilla/websocket v1.5.3/go.mod h1:YR8l580nyteQvAITg2hZ9XVh4b55+EU/adAjf1fMHhE=

     

       52
       +
       github.com/hashicorp/go-cleanhttp v0.5.2 h1:035FKYIWjmULyFRBKPs8TBQoi0x6d9G4xc9neXJWAZQ=

     

       53
       +
       github.com/hashicorp/go-cleanhttp v0.5.2/go.mod h1:kO/YDlP8L1346E6Sodw+PrpBSV4/SoxCXGY6BqNFT48=

     

       54
       +
       github.com/hashicorp/go-hclog v0.9.2 h1:CG6TE5H9/JXsFWJCfoIVpKFIkFe6ysEuHirp4DxCsHI=

     

       55
       +
       github.com/hashicorp/go-hclog v0.9.2/go.mod h1:5CU+agLiy3J7N7QjHK5d05KxGsuXiQLrjA0H7acj2lQ=

     

       56
       +
       github.com/hashicorp/go-retryablehttp v0.7.5 h1:bJj+Pj19UZMIweq/iie+1u5YCdGrnxCT9yvm0e+Nd5M=

     

       57
       +
       github.com/hashicorp/go-retryablehttp v0.7.5/go.mod h1:Jy/gPYAdjqffZ/yFGCFV2doI5wjtH1ewM9u8iYVjtX8=

     

       58
       +
       github.com/hashicorp/golang-lru v1.0.2 h1:dV3g9Z/unq5DpblPpw+Oqcv4dU/1omnb4Ok8iPY6p1c=

     

       59
       +
       github.com/hashicorp/golang-lru v1.0.2/go.mod h1:iADmTwqILo4mZ8BN3D2Q6+9jd8WM5uGBxy+E8yxSoD4=

     

       60
       +
       github.com/hashicorp/golang-lru/v2 v2.0.7 h1:a+bsQ5rvGLjzHuww6tVxozPZFVghXaHOwFs4luLUK2k=

     

       61
       +
       github.com/hashicorp/golang-lru/v2 v2.0.7/go.mod h1:QeFd9opnmA6QUJc5vARoKUSoFhyfM2/ZepoAG6RGpeM=

     

       62
       +
       github.com/huin/goupnp v1.0.3 h1:N8No57ls+MnjlB+JPiCVSOyy/ot7MJTqlo7rn+NYSqQ=

     

       63
       +
       github.com/huin/goupnp v1.0.3/go.mod h1:ZxNlw5WqJj6wSsRK5+YfflQGXYfccj5VgQsMNixHM7Y=

     

       64
       +
       github.com/ipfs/bbloom v0.0.4 h1:Gi+8EGJ2y5qiD5FbsbpX/TMNcJw8gSqr7eyjHa4Fhvs=

     

       65
       +
       github.com/ipfs/bbloom v0.0.4/go.mod h1:cS9YprKXpoZ9lT0n/Mw/a6/aFV6DTjTLYHeA+gyqMG0=

     

       66
       +
       github.com/ipfs/go-bitswap v0.11.0 h1:j1WVvhDX1yhG32NTC9xfxnqycqYIlhzEzLXG/cU1HyQ=

     

       67
       +
       github.com/ipfs/go-bitswap v0.11.0/go.mod h1:05aE8H3XOU+LXpTedeAS0OZpcO1WFsj5niYQH9a1Tmk=

     

       68
       +
       github.com/ipfs/go-block-format v0.2.0 h1:ZqrkxBA2ICbDRbK8KJs/u0O3dlp6gmAuuXUJNiW1Ycs=

     

       69
       +
       github.com/ipfs/go-block-format v0.2.0/go.mod h1:+jpL11nFx5A/SPpsoBn6Bzkra/zaArfSmsknbPMYgzM=

     

       70
       +
       github.com/ipfs/go-blockservice v0.5.2 h1:in9Bc+QcXwd1apOVM7Un9t8tixPKdaHQFdLSUM1Xgk8=

     

       71
       +
       github.com/ipfs/go-blockservice v0.5.2/go.mod h1:VpMblFEqG67A/H2sHKAemeH9vlURVavlysbdUI632yk=

     

       72
       +
       github.com/ipfs/go-cid v0.4.1 h1:A/T3qGvxi4kpKWWcPC/PgbvDA2bjVLO7n4UeVwnbs/s=

     

       73
       +
       github.com/ipfs/go-cid v0.4.1/go.mod h1:uQHwDeX4c6CtyrFwdqyhpNcxVewur1M7l7fNU7LKwZk=

     

       74
       +
       github.com/ipfs/go-datastore v0.6.0 h1:JKyz+Gvz1QEZw0LsX1IBn+JFCJQH4SJVFtM4uWU0Myk=

     

       75
       +
       github.com/ipfs/go-datastore v0.6.0/go.mod h1:rt5M3nNbSO/8q1t4LNkLyUwRs8HupMeN/8O4Vn9YAT8=

     

       76
       +
       github.com/ipfs/go-detect-race v0.0.1 h1:qX/xay2W3E4Q1U7d9lNs1sU9nvguX0a7319XbyQ6cOk=

     

       77
       +
       github.com/ipfs/go-detect-race v0.0.1/go.mod h1:8BNT7shDZPo99Q74BpGMK+4D8Mn4j46UU0LZ723meps=

     

       78
       +
       github.com/ipfs/go-ipfs-blockstore v1.3.1 h1:cEI9ci7V0sRNivqaOr0elDsamxXFxJMMMy7PTTDQNsQ=

     

       79
       +
       github.com/ipfs/go-ipfs-blockstore v1.3.1/go.mod h1:KgtZyc9fq+P2xJUiCAzbRdhhqJHvsw8u2Dlqy2MyRTE=

     

       80
       +
       github.com/ipfs/go-ipfs-blocksutil v0.0.1 h1:Eh/H4pc1hsvhzsQoMEP3Bke/aW5P5rVM1IWFJMcGIPQ=

     

       81
       +
       github.com/ipfs/go-ipfs-blocksutil v0.0.1/go.mod h1:Yq4M86uIOmxmGPUHv/uI7uKqZNtLb449gwKqXjIsnRk=

     

       82
       +
       github.com/ipfs/go-ipfs-delay v0.0.1 h1:r/UXYyRcddO6thwOnhiznIAiSvxMECGgtv35Xs1IeRQ=

     

       83
       +
       github.com/ipfs/go-ipfs-delay v0.0.1/go.mod h1:8SP1YXK1M1kXuc4KJZINY3TQQ03J2rwBG9QfXmbRPrw=

     

       84
       +
       github.com/ipfs/go-ipfs-ds-help v1.1.1 h1:B5UJOH52IbcfS56+Ul+sv8jnIV10lbjLF5eOO0C66Nw=

     

       85
       +
       github.com/ipfs/go-ipfs-ds-help v1.1.1/go.mod h1:75vrVCkSdSFidJscs8n4W+77AtTpCIAdDGAwjitJMIo=

     

       86
       +
       github.com/ipfs/go-ipfs-exchange-interface v0.2.1 h1:jMzo2VhLKSHbVe+mHNzYgs95n0+t0Q69GQ5WhRDZV/s=

     

       87
       +
       github.com/ipfs/go-ipfs-exchange-interface v0.2.1/go.mod h1:MUsYn6rKbG6CTtsDp+lKJPmVt3ZrCViNyH3rfPGsZ2E=

     

       88
       +
       github.com/ipfs/go-ipfs-exchange-offline v0.3.0 h1:c/Dg8GDPzixGd0MC8Jh6mjOwU57uYokgWRFidfvEkuA=

     

       89
       +
       github.com/ipfs/go-ipfs-exchange-offline v0.3.0/go.mod h1:MOdJ9DChbb5u37M1IcbrRB02e++Z7521fMxqCNRrz9s=

     

       90
       +
       github.com/ipfs/go-ipfs-pq v0.0.2 h1:e1vOOW6MuOwG2lqxcLA+wEn93i/9laCY8sXAw76jFOY=

     

       91
       +
       github.com/ipfs/go-ipfs-pq v0.0.2/go.mod h1:LWIqQpqfRG3fNc5XsnIhz/wQ2XXGyugQwls7BgUmUfY=

     

       92
       +
       github.com/ipfs/go-ipfs-routing v0.3.0 h1:9W/W3N+g+y4ZDeffSgqhgo7BsBSJwPMcyssET9OWevc=

     

       93
       +
       github.com/ipfs/go-ipfs-routing v0.3.0/go.mod h1:dKqtTFIql7e1zYsEuWLyuOU+E0WJWW8JjbTPLParDWo=

     

       94
       +
       github.com/ipfs/go-ipfs-util v0.0.3 h1:2RFdGez6bu2ZlZdI+rWfIdbQb1KudQp3VGwPtdNCmE0=

     

       95
       +
       github.com/ipfs/go-ipfs-util v0.0.3/go.mod h1:LHzG1a0Ig4G+iZ26UUOMjHd+lfM84LZCrn17xAKWBvs=

     

       96
       +
       github.com/ipfs/go-ipld-cbor v0.1.0 h1:dx0nS0kILVivGhfWuB6dUpMa/LAwElHPw1yOGYopoYs=

     

       97
       +
       github.com/ipfs/go-ipld-cbor v0.1.0/go.mod h1:U2aYlmVrJr2wsUBU67K4KgepApSZddGRDWBYR0H4sCk=

     

       98
       +
       github.com/ipfs/go-ipld-format v0.6.0 h1:VEJlA2kQ3LqFSIm5Vu6eIlSxD/Ze90xtc4Meten1F5U=

     

       99
       +
       github.com/ipfs/go-ipld-format v0.6.0/go.mod h1:g4QVMTn3marU3qXchwjpKPKgJv+zF+OlaKMyhJ4LHPg=

     

       100
       +
       github.com/ipfs/go-ipld-legacy v0.2.1 h1:mDFtrBpmU7b//LzLSypVrXsD8QxkEWxu5qVxN99/+tk=

     

       101
       +
       github.com/ipfs/go-ipld-legacy v0.2.1/go.mod h1:782MOUghNzMO2DER0FlBR94mllfdCJCkTtDtPM51otM=

     

       102
       +
       github.com/ipfs/go-log v1.0.5 h1:2dOuUCB1Z7uoczMWgAyDck5JLb72zHzrMnGnCNNbvY8=

     

       103
       +
       github.com/ipfs/go-log v1.0.5/go.mod h1:j0b8ZoR+7+R99LD9jZ6+AJsrzkPbSXbZfGakb5JPtIo=

     

       104
       +
       github.com/ipfs/go-log/v2 v2.1.3/go.mod h1:/8d0SH3Su5Ooc31QlL1WysJhvyOTDCjcCZ9Axpmri6g=

     

       105
       +
       github.com/ipfs/go-log/v2 v2.5.1 h1:1XdUzF7048prq4aBjDQQ4SL5RxftpRGdXhNRwKSAlcY=

     

       106
       +
       github.com/ipfs/go-log/v2 v2.5.1/go.mod h1:prSpmC1Gpllc9UYWxDiZDreBYw7zp4Iqp1kOLU9U5UI=

     

       107
       +
       github.com/ipfs/go-merkledag v0.11.0 h1:DgzwK5hprESOzS4O1t/wi6JDpyVQdvm9Bs59N/jqfBY=

     

       108
       +
       github.com/ipfs/go-merkledag v0.11.0/go.mod h1:Q4f/1ezvBiJV0YCIXvt51W/9/kqJGH4I1LsA7+djsM4=

     

       109
       +
       github.com/ipfs/go-metrics-interface v0.0.1 h1:j+cpbjYvu4R8zbleSs36gvB7jR+wsL2fGD6n0jO4kdg=

     

       110
       +
       github.com/ipfs/go-metrics-interface v0.0.1/go.mod h1:6s6euYU4zowdslK0GKHmqaIZ3j/b/tL7HTWtJ4VPgWY=

     

       111
       +
       github.com/ipfs/go-peertaskqueue v0.8.0 h1:JyNO144tfu9bx6Hpo119zvbEL9iQ760FHOiJYsUjqaU=

     

       112
       +
       github.com/ipfs/go-peertaskqueue v0.8.0/go.mod h1:cz8hEnnARq4Du5TGqiWKgMr/BOSQ5XOgMOh1K5YYKKM=

     

       113
       +
       github.com/ipfs/go-verifcid v0.0.3 h1:gmRKccqhWDocCRkC+a59g5QW7uJw5bpX9HWBevXa0zs=

     

       114
       +
       github.com/ipfs/go-verifcid v0.0.3/go.mod h1:gcCtGniVzelKrbk9ooUSX/pM3xlH73fZZJDzQJRvOUw=

     

       115
       +
       github.com/ipld/go-car v0.6.1-0.20230509095817-92d28eb23ba4 h1:oFo19cBmcP0Cmg3XXbrr0V/c+xU9U1huEZp8+OgBzdI=

     

       116
       +
       github.com/ipld/go-car v0.6.1-0.20230509095817-92d28eb23ba4/go.mod h1:6nkFF8OmR5wLKBzRKi7/YFJpyYR7+oEn1DX+mMWnlLA=

     

       117
       +
       github.com/ipld/go-car/v2 v2.13.1 h1:KnlrKvEPEzr5IZHKTXLAEub+tPrzeAFQVRlSQvuxBO4=

     

       118
       +
       github.com/ipld/go-car/v2 v2.13.1/go.mod h1:QkdjjFNGit2GIkpQ953KBwowuoukoM75nP/JI1iDJdo=

     

       119
       +
       github.com/ipld/go-codec-dagpb v1.6.0 h1:9nYazfyu9B1p3NAgfVdpRco3Fs2nFC72DqVsMj6rOcc=

     

       120
       +
       github.com/ipld/go-codec-dagpb v1.6.0/go.mod h1:ANzFhfP2uMJxRBr8CE+WQWs5UsNa0pYtmKZ+agnUw9s=

     

       121
       +
       github.com/ipld/go-ipld-prime v0.21.0 h1:n4JmcpOlPDIxBcY037SVfpd1G+Sj1nKZah0m6QH9C2E=

     

       122
       +
       github.com/ipld/go-ipld-prime v0.21.0/go.mod h1:3RLqy//ERg/y5oShXXdx5YIp50cFGOanyMctpPjsvxQ=

     

       123
       +
       github.com/jackpal/go-nat-pmp v1.0.2 h1:KzKSgb7qkJvOUTqYl9/Hg/me3pWgBmERKrTGD7BdWus=

     

       124
       +
       github.com/jackpal/go-nat-pmp v1.0.2/go.mod h1:QPH045xvCAeXUZOxsnwmrtiCoxIr9eob+4orBN1SBKc=

     

       125
       +
       github.com/jbenet/go-cienv v0.1.0/go.mod h1:TqNnHUmJgXau0nCzC7kXWeotg3J9W34CUv5Djy1+FlA=

     

       126
       +
       github.com/jbenet/goprocess v0.1.4 h1:DRGOFReOMqqDNXwW70QkacFW0YN9QnwLV0Vqk+3oU0o=

     

       127
       +
       github.com/jbenet/goprocess v0.1.4/go.mod h1:5yspPrukOVuOLORacaBi858NqyClJPQxYZlqdZVfqY4=

     

       128
       +
       github.com/jtolds/gls v4.20.0+incompatible h1:xdiiI2gbIgH/gLH7ADydsJ1uDOEzR8yvV7C0MuV77Wo=

     

       129
       +
       github.com/jtolds/gls v4.20.0+incompatible/go.mod h1:QJZ7F/aHp+rZTRtaJ1ow/lLfFfVYBRgL+9YlvaHOwJU=

     

       130
       +
       github.com/kisielk/errcheck v1.5.0/go.mod h1:pFxgyoBC7bSaBwPgfKdkLd5X25qrDl4LWUI2bnpBCr8=

     

       131
       +
       github.com/kisielk/gotool v1.0.0/go.mod h1:XhKaO+MFFWcvkIS/tQcRk01m1F5IRFswLeQ+oQHNcck=

     

       132
       +
       github.com/klauspost/cpuid/v2 v2.2.7 h1:ZWSB3igEs+d0qvnxR/ZBzXVmxkgt8DdzP6m9pfuVLDM=

     

       133
       +
       github.com/klauspost/cpuid/v2 v2.2.7/go.mod h1:Lcz8mBdAVJIBVzewtcLocK12l3Y+JytZYpaMropDUws=

     

       134
       +
       github.com/koron/go-ssdp v0.0.3 h1:JivLMY45N76b4p/vsWGOKewBQu6uf39y8l+AQ7sDKx8=

     

       135
       +
       github.com/koron/go-ssdp v0.0.3/go.mod h1:b2MxI6yh02pKrsyNoQUsk4+YNikaGhe4894J+Q5lDvA=

     

       136
       +
       github.com/kr/pretty v0.1.0/go.mod h1:dAy3ld7l9f0ibDNOQOHHMYYIIbhfbHSm3C4ZsoJORNo=

     

       137
       +
       github.com/kr/pretty v0.3.1 h1:flRD4NNwYAUpkphVc1HcthR4KEIFJ65n8Mw5qdRn3LE=

     

       138
       +
       github.com/kr/pretty v0.3.1/go.mod h1:hoEshYVHaxMs3cyo3Yncou5ZscifuDolrwPKZanG3xk=

     

       139
       +
       github.com/kr/pty v1.1.1/go.mod h1:pFQYn66WHrOpPYNljwOMqo10TkYh1fy3cYio2l3bCsQ=

     

       140
       +
       github.com/kr/text v0.1.0/go.mod h1:4Jbv+DJW3UT/LiOwJeYQe1efqtUx/iVham/4vfdArNI=

     

       141
       +
       github.com/kr/text v0.2.0 h1:5Nx0Ya0ZqY2ygV366QzturHI13Jq95ApcVaJBhpS+AY=

     

       142
       +
       github.com/kr/text v0.2.0/go.mod h1:eLer722TekiGuMkidMxC/pM04lWEeraHUUmBw8l2grE=

     

       143
       +
       github.com/libp2p/go-buffer-pool v0.1.0 h1:oK4mSFcQz7cTQIfqbe4MIj9gLW+mnanjyFtc6cdF0Y8=

     

       144
       +
       github.com/libp2p/go-buffer-pool v0.1.0/go.mod h1:N+vh8gMqimBzdKkSMVuydVDq+UV5QTWy5HSiZacSbPg=

     

       145
       +
       github.com/libp2p/go-cidranger v1.1.0 h1:ewPN8EZ0dd1LSnrtuwd4709PXVcITVeuwbag38yPW7c=

     

       146
       +
       github.com/libp2p/go-cidranger v1.1.0/go.mod h1:KWZTfSr+r9qEo9OkI9/SIEeAtw+NNoU0dXIXt15Okic=

     

       147
       +
       github.com/libp2p/go-libp2p v0.22.0 h1:2Tce0kHOp5zASFKJbNzRElvh0iZwdtG5uZheNW8chIw=

     

       148
       +
       github.com/libp2p/go-libp2p v0.22.0/go.mod h1:UDolmweypBSjQb2f7xutPnwZ/fxioLbMBxSjRksxxU4=

     

       149
       +
       github.com/libp2p/go-libp2p-asn-util v0.2.0 h1:rg3+Os8jbnO5DxkC7K/Utdi+DkY3q/d1/1q+8WeNAsw=

     

       150
       +
       github.com/libp2p/go-libp2p-asn-util v0.2.0/go.mod h1:WoaWxbHKBymSN41hWSq/lGKJEca7TNm58+gGJi2WsLI=

     

       151
       +
       github.com/libp2p/go-libp2p-record v0.2.0 h1:oiNUOCWno2BFuxt3my4i1frNrt7PerzB3queqa1NkQ0=

     

       152
       +
       github.com/libp2p/go-libp2p-record v0.2.0/go.mod h1:I+3zMkvvg5m2OcSdoL0KPljyJyvNDFGKX7QdlpYUcwk=

     

       153
       +
       github.com/libp2p/go-libp2p-testing v0.12.0 h1:EPvBb4kKMWO29qP4mZGyhVzUyR25dvfUIK5WDu6iPUA=

     

       154
       +
       github.com/libp2p/go-libp2p-testing v0.12.0/go.mod h1:KcGDRXyN7sQCllucn1cOOS+Dmm7ujhfEyXQL5lvkcPg=

     

       155
       +
       github.com/libp2p/go-msgio v0.2.0 h1:W6shmB+FeynDrUVl2dgFQvzfBZcXiyqY4VmpQLu9FqU=

     

       156
       +
       github.com/libp2p/go-msgio v0.2.0/go.mod h1:dBVM1gW3Jk9XqHkU4eKdGvVHdLa51hoGfll6jMJMSlY=

     

       157
       +
       github.com/libp2p/go-nat v0.1.0 h1:MfVsH6DLcpa04Xr+p8hmVRG4juse0s3J8HyNWYHffXg=

     

       158
       +
       github.com/libp2p/go-nat v0.1.0/go.mod h1:X7teVkwRHNInVNWQiO/tAiAVRwSr5zoRz4YSTC3uRBM=

     

       159
       +
       github.com/libp2p/go-netroute v0.2.0 h1:0FpsbsvuSnAhXFnCY0VLFbJOzaK0VnP0r1QT/o4nWRE=

     

       160
       +
       github.com/libp2p/go-netroute v0.2.0/go.mod h1:Vio7LTzZ+6hoT4CMZi5/6CpY3Snzh2vgZhWgxMNwlQI=

     

       161
       +
       github.com/libp2p/go-openssl v0.1.0 h1:LBkKEcUv6vtZIQLVTegAil8jbNpJErQ9AnT+bWV+Ooo=

     

       162
       +
       github.com/libp2p/go-openssl v0.1.0/go.mod h1:OiOxwPpL3n4xlenjx2h7AwSGaFSC/KZvf6gNdOBQMtc=

     

       163
       +
       github.com/mattn/go-isatty v0.0.14/go.mod h1:7GGIvUiUoEMVVmxf/4nioHXj79iQHKdU27kJ6hsGG94=

     

       164
       +
       github.com/mattn/go-isatty v0.0.20 h1:xfD0iDuEKnDkl03q4limB+vH+GxLEtL/jb4xVJSWWEY=

     

       165
       +
       github.com/mattn/go-isatty v0.0.20/go.mod h1:W+V8PltTTMOvKvAeJH7IuucS94S2C6jfK/D7dTCTo3Y=

     

       166
       +
       github.com/mattn/go-pointer v0.0.1 h1:n+XhsuGeVO6MEAp7xyEukFINEa+Quek5psIR/ylA6o0=

     

       167
       +
       github.com/mattn/go-pointer v0.0.1/go.mod h1:2zXcozF6qYGgmsG+SeTZz3oAbFLdD3OWqnUbNvJZAlc=

     

       168
       +
       github.com/matttproud/golang_protobuf_extensions/v2 v2.0.0 h1:jWpvCLoY8Z/e3VKvlsiIGKtc+UG6U5vzxaoagmhXfyg=

     

       169
       +
       github.com/matttproud/golang_protobuf_extensions/v2 v2.0.0/go.mod h1:QUyp042oQthUoa9bqDv0ER0wrtXnBruoNd7aNjkbP+k=

     

       170
       +
       github.com/miekg/dns v1.1.50 h1:DQUfb9uc6smULcREF09Uc+/Gd46YWqJd5DbpPE9xkcA=

     

       171
       +
       github.com/miekg/dns v1.1.50/go.mod h1:e3IlAVfNqAllflbibAZEWOXOQ+Ynzk/dDozDxY7XnME=

     

       172
       +
       github.com/minio/sha256-simd v1.0.1 h1:6kaan5IFmwTNynnKKpDHe6FWHohJOHhCPchzK49dzMM=

     

       173
       +
       github.com/minio/sha256-simd v1.0.1/go.mod h1:Pz6AKMiUdngCLpeTL/RJY1M9rUuPMYujV5xJjtbRSN8=

     

       174
       +
       github.com/mr-tron/base58 v1.2.0 h1:T/HDJBh4ZCPbU39/+c3rRvE0uKBQlU27+QI8LJ4t64o=

     

       175
       +
       github.com/mr-tron/base58 v1.2.0/go.mod h1:BinMc/sQntlIE1frQmRFPUoPA1Zkr8VRgBdjWI2mNwc=

     

       176
       +
       github.com/multiformats/go-base32 v0.1.0 h1:pVx9xoSPqEIQG8o+UbAe7DNi51oej1NtK+aGkbLYxPE=

     

       177
       +
       github.com/multiformats/go-base32 v0.1.0/go.mod h1:Kj3tFY6zNr+ABYMqeUNeGvkIC/UYgtWibDcT0rExnbI=

     

       178
       +
       github.com/multiformats/go-base36 v0.2.0 h1:lFsAbNOGeKtuKozrtBsAkSVhv1p9D0/qedU9rQyccr0=

     

       179
       +
       github.com/multiformats/go-base36 v0.2.0/go.mod h1:qvnKE++v+2MWCfePClUEjE78Z7P2a1UV0xHgWc0hkp4=

     

       180
       +
       github.com/multiformats/go-multiaddr v0.7.0 h1:gskHcdaCyPtp9XskVwtvEeQOG465sCohbQIirSyqxrc=

     

       181
       +
       github.com/multiformats/go-multiaddr v0.7.0/go.mod h1:Fs50eBDWvZu+l3/9S6xAE7ZYj6yhxlvaVZjakWN7xRs=

     

       182
       +
       github.com/multiformats/go-multiaddr-dns v0.3.1 h1:QgQgR+LQVt3NPTjbrLLpsaT2ufAA2y0Mkk+QRVJbW3A=

     

       183
       +
       github.com/multiformats/go-multiaddr-dns v0.3.1/go.mod h1:G/245BRQ6FJGmryJCrOuTdB37AMA5AMOVuO6NY3JwTk=

     

       184
       +
       github.com/multiformats/go-multiaddr-fmt v0.1.0 h1:WLEFClPycPkp4fnIzoFoV9FVd49/eQsuaL3/CWe167E=

     

       185
       +
       github.com/multiformats/go-multiaddr-fmt v0.1.0/go.mod h1:hGtDIW4PU4BqJ50gW2quDuPVjyWNZxToGUh/HwTZYJo=

     

       186
       +
       github.com/multiformats/go-multibase v0.2.0 h1:isdYCVLvksgWlMW9OZRYJEa9pZETFivncJHmHnnd87g=

     

       187
       +
       github.com/multiformats/go-multibase v0.2.0/go.mod h1:bFBZX4lKCA/2lyOFSAoKH5SS6oPyjtnzK/XTFDPkNuk=

     

       188
       +
       github.com/multiformats/go-multicodec v0.9.0 h1:pb/dlPnzee/Sxv/j4PmkDRxCOi3hXTz3IbPKOXWJkmg=

     

       189
       +
       github.com/multiformats/go-multicodec v0.9.0/go.mod h1:L3QTQvMIaVBkXOXXtVmYE+LI16i14xuaojr/H7Ai54k=

     

       190
       +
       github.com/multiformats/go-multihash v0.2.3 h1:7Lyc8XfX/IY2jWb/gI7JP+o7JEq9hOa7BFvVU9RSh+U=

     

       191
       +
       github.com/multiformats/go-multihash v0.2.3/go.mod h1:dXgKXCXjBzdscBLk9JkjINiEsCKRVch90MdaGiKsvSM=

     

       192
       +
       github.com/multiformats/go-multistream v0.3.3 h1:d5PZpjwRgVlbwfdTDjife7XszfZd8KYWfROYFlGcR8o=

     

       193
       +
       github.com/multiformats/go-multistream v0.3.3/go.mod h1:ODRoqamLUsETKS9BNcII4gcRsJBU5VAwRIv7O39cEXg=

     

       194
       +
       github.com/multiformats/go-varint v0.0.7 h1:sWSGR+f/eu5ABZA2ZpYKBILXTTs9JWpdEM/nEGOHFS8=

     

       195
       +
       github.com/multiformats/go-varint v0.0.7/go.mod h1:r8PUYw/fD/SjBCiKOoDlGF6QawOELpZAu9eioSos/OU=

     

       196
       +
       github.com/ncruces/go-strftime v0.1.9 h1:bY0MQC28UADQmHmaF5dgpLmImcShSi2kHU9XLdhx/f4=

     

       197
       +
       github.com/ncruces/go-strftime v0.1.9/go.mod h1:Fwc5htZGVVkseilnfgOVb9mKy6w1naJmn9CehxcKcls=

     

       198
       +
       github.com/opentracing/opentracing-go v1.2.0 h1:uEJPy/1a5RIPAJ0Ov+OIO8OxWu77jEv+1B0VhjKrZUs=

     

       199
       +
       github.com/opentracing/opentracing-go v1.2.0/go.mod h1:GxEUsuufX4nBwe+T+Wl9TAgYrxe9dPLANfrWvHYVTgc=

     

       200
       +
       github.com/petar/GoLLRB v0.0.0-20210522233825-ae3b015fd3e9 h1:1/WtZae0yGtPq+TI6+Tv1WTxkukpXeMlviSxvL7SRgk=

     

       201
       +
       github.com/petar/GoLLRB v0.0.0-20210522233825-ae3b015fd3e9/go.mod h1:x3N5drFsm2uilKKuuYo6LdyD8vZAW55sH/9w+pbo1sw=

     

       202
       +
       github.com/pkg/errors v0.8.1/go.mod h1:bwawxfHBFNV+L2hUp1rHADufV3IMtnDRdf1r5NINEl0=

     

       203
       +
       github.com/pmezard/go-difflib v1.0.0 h1:4DBwDE0NGyQoBHbLQYPwSUPoCMWR5BEzIk/f1lZbAQM=

     

       204
       +
       github.com/pmezard/go-difflib v1.0.0/go.mod h1:iKH77koFhYxTK1pcRnkKkqfTogsbg7gZNVY4sRDYZ/4=

     

       205
       +
       github.com/polydawn/refmt v0.89.1-0.20221221234430-40501e09de1f h1:VXTQfuJj9vKR4TCkEuWIckKvdHFeJH/huIFJ9/cXOB0=

     

       206
       +
       github.com/polydawn/refmt v0.89.1-0.20221221234430-40501e09de1f/go.mod h1:/zvteZs/GwLtCgZ4BL6CBsk9IKIlexP43ObX9AxTqTw=

     

       207
       +
       github.com/prometheus/client_golang v1.17.0 h1:rl2sfwZMtSthVU752MqfjQozy7blglC+1SOtjMAMh+Q=

     

       208
       +
       github.com/prometheus/client_golang v1.17.0/go.mod h1:VeL+gMmOAxkS2IqfCq0ZmHSL+LjWfWDUmp1mBz9JgUY=

     

       209
       +
       github.com/prometheus/client_model v0.5.0 h1:VQw1hfvPvk3Uv6Qf29VrPF32JB6rtbgI6cYPYQjL0Qw=

     

       210
       +
       github.com/prometheus/client_model v0.5.0/go.mod h1:dTiFglRmd66nLR9Pv9f0mZi7B7fk5Pm3gvsjB5tr+kI=

     

       211
       +
       github.com/prometheus/common v0.45.0 h1:2BGz0eBc2hdMDLnO/8n0jeB3oPrt2D08CekT0lneoxM=

     

       212
       +
       github.com/prometheus/common v0.45.0/go.mod h1:YJmSTw9BoKxJplESWWxlbyttQR4uaEcGyv9MZjVOJsY=

     

       213
       +
       github.com/prometheus/procfs v0.12.0 h1:jluTpSng7V9hY0O2R9DzzJHYb2xULk9VTR1V1R/k6Bo=

     

       214
       +
       github.com/prometheus/procfs v0.12.0/go.mod h1:pcuDEFsWDnvcgNzo4EEweacyhjeA9Zk3cnaOZAZEfOo=

     

       215
       +
       github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec h1:W09IVJc94icq4NjY3clb7Lk8O1qJ8BdBEF8z0ibU0rE=

     

       216
       +
       github.com/remyoudompheng/bigfft v0.0.0-20230129092748-24d4a6f8daec/go.mod h1:qqbHyh8v60DhA7CoWK5oRCqLrMHRGoxYCSS9EjAz6Eo=

     

       217
       +
       github.com/rogpeppe/go-internal v1.3.0/go.mod h1:M8bDsm7K2OlrFYOpmOWEs/qY81heoFRclV5y23lUDJ4=

     

       218
       +
       github.com/rogpeppe/go-internal v1.10.0 h1:TMyTOH3F/DB16zRVcYyreMH6GnZZrwQVAoYjRBZyWFQ=

     

       219
       +
       github.com/rogpeppe/go-internal v1.10.0/go.mod h1:UQnix2H7Ngw/k4C5ijL5+65zddjncjaFoBhdsK/akog=

     

       220
       +
       github.com/russross/blackfriday/v2 v2.0.1/go.mod h1:+Rmxgy9KzJVeS9/2gXHxylqXiyQDYRxCVz55jmeOWTM=

     

       221
       +
       github.com/shurcooL/sanitized_anchor_name v1.0.0/go.mod h1:1NzhyTcUVG4SuEtjjoZeVRXNmyL/1OwPU0+IJeTBvfc=

     

       222
       +
       github.com/smartystreets/assertions v1.2.0 h1:42S6lae5dvLc7BrLu/0ugRtcFVjoJNMC/N3yZFZkDFs=

     

       223
       +
       github.com/smartystreets/assertions v1.2.0/go.mod h1:tcbTF8ujkAEcZ8TElKY+i30BzYlVhC/LOxJk7iOWnoo=

     

       224
       +
       github.com/smartystreets/goconvey v1.7.2 h1:9RBaZCeXEQ3UselpuwUQHltGVXvdwm6cv1hgR6gDIPg=

     

       225
       +
       github.com/smartystreets/goconvey v1.7.2/go.mod h1:Vw0tHAZW6lzCRk3xgdin6fKYcG+G3Pg9vgXWeJpQFMM=

     

       226
       +
       github.com/spacemonkeygo/spacelog v0.0.0-20180420211403-2296661a0572 h1:RC6RW7j+1+HkWaX/Yh71Ee5ZHaHYt7ZP4sQgUrm6cDU=

     

       227
       +
       github.com/spacemonkeygo/spacelog v0.0.0-20180420211403-2296661a0572/go.mod h1:w0SWMsp6j9O/dk4/ZpIhL+3CkG8ofA2vuv7k+ltqUMc=

     

       228
       +
       github.com/spaolacci/murmur3 v1.1.0 h1:7c1g84S4BPRrfL5Xrdp6fOJ206sU9y293DDHaoy0bLI=

     

       229
       +
       github.com/spaolacci/murmur3 v1.1.0/go.mod h1:JwIasOWyU6f++ZhiEuf87xNszmSA2myDM2Kzu9HwQUA=

     

       230
       +
       github.com/stretchr/objx v0.1.0/go.mod h1:HFkY916IF+rwdDfMAkV7OtwuqBVzrE8GR6GFx+wExME=

     

       231
       +
       github.com/stretchr/testify v1.2.2/go.mod h1:a8OnRcib4nhh0OaRAV+Yts87kKdq0PP7pXfy6kDkUVs=

     

       232
       +
       github.com/stretchr/testify v1.3.0/go.mod h1:M5WIy9Dh21IEIfnGCwXGc5bZfKNJtfHm1UVUgZn+9EI=

     

       233
       +
       github.com/stretchr/testify v1.4.0/go.mod h1:j7eGeouHqKxXV5pUuKE4zz7dFj8WfuZ+81PSLYec5m4=

     

       234
       +
       github.com/stretchr/testify v1.7.0/go.mod h1:6Fq8oRcR53rry900zMqJjRRixrwX3KX962/h/Wwjteg=

     

       235
       +
       github.com/stretchr/testify v1.9.0 h1:HtqpIVDClZ4nwg75+f6Lvsy/wHu+3BoSGCbBAcpTsTg=

     

       236
       +
       github.com/stretchr/testify v1.9.0/go.mod h1:r2ic/lqez/lEtzL7wO/rwa5dbSLXVDPFyf8C91i36aY=

     

       237
       +
       github.com/urfave/cli v1.22.10/go.mod h1:Gos4lmkARVdJ6EkW0WaNv/tZAAMe9V7XWyB60NtXRu0=

     

       238
       +
       github.com/warpfork/go-testmark v0.12.1 h1:rMgCpJfwy1sJ50x0M0NgyphxYYPMOODIJHhsXyEHU0s=

     

       239
       +
       github.com/warpfork/go-testmark v0.12.1/go.mod h1:kHwy7wfvGSPh1rQJYKayD4AbtNaeyZdcGi9tNJTaa5Y=

     

       240
       +
       github.com/warpfork/go-wish v0.0.0-20220906213052-39a1cc7a02d0 h1:GDDkbFiaK8jsSDJfjId/PEGEShv6ugrt4kYsC5UIDaQ=

     

       241
       +
       github.com/warpfork/go-wish v0.0.0-20220906213052-39a1cc7a02d0/go.mod h1:x6AKhvSSexNrVSrViXSHUEbICjmGXhtgABaHIySUSGw=

     

       242
       +
       github.com/whyrusleeping/cbor v0.0.0-20171005072247-63513f603b11 h1:5HZfQkwe0mIfyDmc1Em5GqlNRzcdtlv4HTNmdpt7XH0=

     

       243
       +
       github.com/whyrusleeping/cbor v0.0.0-20171005072247-63513f603b11/go.mod h1:Wlo/SzPmxVp6vXpGt/zaXhHH0fn4IxgqZc82aKg6bpQ=

     

       244
       +
       github.com/whyrusleeping/cbor-gen v0.2.1-0.20241030202151-b7a6831be65e h1:28X54ciEwwUxyHn9yrZfl5ojgF4CBNLWX7LR0rvBkf4=

     

       245
       +
       github.com/whyrusleeping/cbor-gen v0.2.1-0.20241030202151-b7a6831be65e/go.mod h1:pM99HXyEbSQHcosHc0iW7YFmwnscr+t9Te4ibko05so=

     

       246
       +
       github.com/x448/float16 v0.8.4 h1:qLwI1I70+NjRFUR3zs1JPUCgaCXSh3SW62uAKT1mSBM=

     

       247
       +
       github.com/x448/float16 v0.8.4/go.mod h1:14CWIYCyZA/cWjXOioeEpHeN/83MdbZDRQHoFcYsOfg=

     

       248
       +
       github.com/yuin/goldmark v1.1.27/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=

     

       249
       +
       github.com/yuin/goldmark v1.2.1/go.mod h1:3hX8gzYuyVAZsxl0MRgGTJEmQBFcNTphYh9decYSb74=

     

       250
       +
       github.com/yuin/goldmark v1.3.5/go.mod h1:mwnBkeHKe2W/ZEtQ+71ViKU8L12m81fl3OWwC1Zlc8k=

     

       251
       +
       gitlab.com/yawning/secp256k1-voi v0.0.0-20230925100816-f2616030848b h1:CzigHMRySiX3drau9C6Q5CAbNIApmLdat5jPMqChvDA=

     

       252
       +
       gitlab.com/yawning/secp256k1-voi v0.0.0-20230925100816-f2616030848b/go.mod h1:/y/V339mxv2sZmYYR64O07VuCpdNZqCTwO8ZcouTMI8=

     

       253
       +
       gitlab.com/yawning/tuplehash v0.0.0-20230713102510-df83abbf9a02 h1:qwDnMxjkyLmAFgcfgTnfJrmYKWhHnci3GjDqcZp1M3Q=

     

       254
       +
       gitlab.com/yawning/tuplehash v0.0.0-20230713102510-df83abbf9a02/go.mod h1:JTnUj0mpYiAsuZLmKjTx/ex3AtMowcCgnE7YNyCEP0I=

     

       255
       +
       go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.46.1 h1:aFJWCqJMNjENlcleuuOkGAPH82y0yULBScfXcIEdS24=

     

       256
       +
       go.opentelemetry.io/contrib/instrumentation/net/http/otelhttp v0.46.1/go.mod h1:sEGXWArGqc3tVa+ekntsN65DmVbVeW+7lTKTjZF3/Fo=

     

       257
       +
       go.opentelemetry.io/otel v1.21.0 h1:hzLeKBZEL7Okw2mGzZ0cc4k/A7Fta0uoPgaJCr8fsFc=

     

       258
       +
       go.opentelemetry.io/otel v1.21.0/go.mod h1:QZzNPQPm1zLX4gZK4cMi+71eaorMSGT3A4znnUvNNEo=

     

       259
       +
       go.opentelemetry.io/otel/metric v1.21.0 h1:tlYWfeo+Bocx5kLEloTjbcDwBuELRrIFxwdQ36PlJu4=

     

       260
       +
       go.opentelemetry.io/otel/metric v1.21.0/go.mod h1:o1p3CA8nNHW8j5yuQLdc1eeqEaPfzug24uvsyIEJRWM=

     

       261
       +
       go.opentelemetry.io/otel/trace v1.21.0 h1:WD9i5gzvoUPuXIXH24ZNBudiarZDKuekPqi/E8fpfLc=

     

       262
       +
       go.opentelemetry.io/otel/trace v1.21.0/go.mod h1:LGbsEB0f9LGjN+OZaQQ26sohbOmiMR+BaslueVtS/qQ=

     

       263
       +
       go.uber.org/atomic v1.6.0/go.mod h1:sABNBOSYdrvTF6hTgEIbc7YasKWGhgEQZyfxyTvoXHQ=

     

       264
       +
       go.uber.org/atomic v1.7.0/go.mod h1:fEN4uk6kAWBTFdckzkM89CLk9XfWZrxpCo0nPH17wJc=

     

       265
       +
       go.uber.org/atomic v1.11.0 h1:ZvwS0R+56ePWxUNi+Atn9dWONBPp/AUETXlHW0DxSjE=

     

       266
       +
       go.uber.org/atomic v1.11.0/go.mod h1:LUxbIzbOniOlMKjJjyPfpl4v+PKK2cNJn91OQbhoJI0=

     

       267
       +
       go.uber.org/goleak v1.1.11-0.20210813005559-691160354723/go.mod h1:cwTWslyiVhfpKIDGSZEM2HlOvcqm+tG4zioyIeLoqMQ=

     

       268
       +
       go.uber.org/goleak v1.2.0 h1:xqgm/S+aQvhWFTtR0XK3Jvg7z8kGV8P4X14IzwN3Eqk=

     

       269
       +
       go.uber.org/goleak v1.2.0/go.mod h1:XJYK+MuIchqpmGmUSAzotztawfKvYLUIgg7guXrwVUo=

     

       270
       +
       go.uber.org/multierr v1.5.0/go.mod h1:FeouvMocqHpRaaGuG9EjoKcStLC43Zu/fmqdUMPcKYU=

     

       271
       +
       go.uber.org/multierr v1.6.0/go.mod h1:cdWPpRnG4AhwMwsgIHip0KRBQjJy5kYEpYjJxpXp9iU=

     

       272
       +
       go.uber.org/multierr v1.11.0 h1:blXXJkSxSSfBVBlC76pxqeO+LN3aDfLQo+309xJstO0=

     

       273
       +
       go.uber.org/multierr v1.11.0/go.mod h1:20+QtiLqy0Nd6FdQB9TLXag12DsQkrbs3htMFfDN80Y=

     

       274
       +
       go.uber.org/tools v0.0.0-20190618225709-2cfd321de3ee/go.mod h1:vJERXedbb3MVM5f9Ejo0C68/HhF8uaILCdgjnY+goOA=

     

       275
       +
       go.uber.org/zap v1.16.0/go.mod h1:MA8QOfq0BHJwdXa996Y4dYkAqRKB8/1K1QMMZVaNZjQ=

     

       276
       +
       go.uber.org/zap v1.19.1/go.mod h1:j3DNczoxDZroyBnOT1L/Q79cfUMGZxlv/9dzN7SM1rI=

     

       277
       +
       go.uber.org/zap v1.26.0 h1:sI7k6L95XOKS281NhVKOFCUNIvv9e0w4BF8N3u+tCRo=

     

       278
       +
       go.uber.org/zap v1.26.0/go.mod h1:dtElttAiwGvoJ/vj4IwHBS/gXsEu/pZ50mUIRWuG0so=

     

       279
       +
       golang.org/x/crypto v0.0.0-20190308221718-c2843e01d9a2/go.mod h1:djNgcEr1/C05ACkg1iLfiJU5Ep61QUkGW8qpdssI0+w=

     

       280
       +
       golang.org/x/crypto v0.0.0-20190510104115-cbcb75029529/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=

     

       281
       +
       golang.org/x/crypto v0.0.0-20191011191535-87dc89f01550/go.mod h1:yigFU9vqHzYiE8UmvKecakEJjdnWj3jj499lnFckfCI=

     

       282
       +
       golang.org/x/crypto v0.0.0-20200622213623-75b288015ac9/go.mod h1:LzIPMQfyMNhhGPhUkYOs5KpL4U8rLKemX1yGLhDgUto=

     

       283
       +
       golang.org/x/crypto v0.21.0 h1:X31++rzVUdKhX5sWmSOFZxx8UW/ldWx55cbf08iNAMA=

     

       284
       +
       golang.org/x/crypto v0.21.0/go.mod h1:0BP7YvVV9gBbVKyeTG0Gyn+gZm94bibOW5BjDEYAOMs=

     

       285
       +
       golang.org/x/exp v0.0.0-20250408133849-7e4ce0ab07d0 h1:R84qjqJb5nVJMxqWYb3np9L5ZsaDtB+a39EqjV0JSUM=

     

       286
       +
       golang.org/x/exp v0.0.0-20250408133849-7e4ce0ab07d0/go.mod h1:S9Xr4PYopiDyqSyp5NjCrhFrqg6A5zA2E/iPHPhqnS8=

     

       287
       +
       golang.org/x/lint v0.0.0-20190930215403-16217165b5de/go.mod h1:6SW0HCj/g11FgYtHlgUYUwCkIfeOF89ocIRzGO/8vkc=

     

       288
       +
       golang.org/x/mod v0.0.0-20190513183733-4bf6d317e70e/go.mod h1:mXi4GBBbnImb6dmsKGUJ2LatrhH/nqhxcFungHvyanc=

     

       289
       +
       golang.org/x/mod v0.2.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=

     

       290
       +
       golang.org/x/mod v0.3.0/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=

     

       291
       +
       golang.org/x/mod v0.4.2/go.mod h1:s0Qsj1ACt9ePp/hMypM3fl4fZqREWJwdYDEqhRiZZUA=

     

       292
       +
       golang.org/x/mod v0.24.0 h1:ZfthKaKaT4NrhGVZHO1/WDTwGES4De8KtWO0SIbNJMU=

     

       293
       +
       golang.org/x/mod v0.24.0/go.mod h1:IXM97Txy2VM4PJ3gI61r1YEk/gAj6zAHN3AdZt6S9Ww=

     

       294
       +
       golang.org/x/net v0.0.0-20190311183353-d8887717615a/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=

     

       295
       +
       golang.org/x/net v0.0.0-20190404232315-eb5bcb51f2a3/go.mod h1:t9HGtf8HONx5eT2rtn7q6eTqICYqUVnKs3thJo3Qplg=

     

       296
       +
       golang.org/x/net v0.0.0-20190620200207-3b0461eec859/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=

     

       297
       +
       golang.org/x/net v0.0.0-20200226121028-0de0cce0169b/go.mod h1:z5CRVTTTmAJ677TzLLGU+0bjPO0LkuOLi4/5GtJWs/s=

     

       298
       +
       golang.org/x/net v0.0.0-20201021035429-f5854403a974/go.mod h1:sp8m0HH+o8qH0wwXwYZr8TS3Oi6o0r6Gce1SSxlDquU=

     

       299
       +
       golang.org/x/net v0.0.0-20210405180319-a5a99cb37ef4/go.mod h1:p54w0d4576C0XHj96bSt6lcn1PtDYWL6XObtHCRCNQM=

     

       300
       +
       golang.org/x/net v0.23.0 h1:7EYJ93RZ9vYSZAIb2x3lnuvqO5zneoD6IvWjuhfxjTs=

     

       301
       +
       golang.org/x/net v0.23.0/go.mod h1:JKghWKKOSdJwpW2GEx0Ja7fmaKnMsbu+MWVZTokSYmg=

     

       302
       +
       golang.org/x/sync v0.0.0-20190423024810-112230192c58/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=

     

       303
       +
       golang.org/x/sync v0.0.0-20190911185100-cd5d95a43a6e/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=

     

       304
       +
       golang.org/x/sync v0.0.0-20201020160332-67f06af15bc9/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=

     

       305
       +
       golang.org/x/sync v0.0.0-20210220032951-036812b2e83c/go.mod h1:RxMgew5VJxzue5/jJTE5uejpjVlOe/izrB70Jof72aM=

     

       306
       +
       golang.org/x/sync v0.14.0 h1:woo0S4Yywslg6hp4eUFjTVOyKt0RookbpAHG4c1HmhQ=

     

       307
       +
       golang.org/x/sync v0.14.0/go.mod h1:1dzgHSNfp02xaA81J2MS99Qcpr2w7fw1gpm99rleRqA=

     

       308
       +
       golang.org/x/sys v0.0.0-20190215142949-d0b11bdaac8a/go.mod h1:STP8DvDyc/dI5b8T5hshtkjS+E42TnysNCUPdjciGhY=

     

       309
       +
       golang.org/x/sys v0.0.0-20190412213103-97732733099d/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=

     

       310
       +
       golang.org/x/sys v0.0.0-20200930185726-fdedc70b468f/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=

     

       311
       +
       golang.org/x/sys v0.0.0-20201119102817-f84b799fce68/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=

     

       312
       +
       golang.org/x/sys v0.0.0-20210330210617-4fbd30eecc44/go.mod h1:h1NjWce9XRLGQEsW7wpKNCjG9DtNlClVuFLEZdDNbEs=

     

       313
       +
       golang.org/x/sys v0.0.0-20210510120138-977fb7262007/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

     

       314
       +
       golang.org/x/sys v0.0.0-20210630005230-0f9fa26af87c/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

     

       315
       +
       golang.org/x/sys v0.5.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

     

       316
       +
       golang.org/x/sys v0.6.0/go.mod h1:oPkhp1MJrh7nUepCBck5+mAzfO9JrbApNNgaTdGDITg=

     

       317
       +
       golang.org/x/sys v0.33.0 h1:q3i8TbbEz+JRD9ywIRlyRAQbM0qF7hu24q3teo2hbuw=

     

       318
       +
       golang.org/x/sys v0.33.0/go.mod h1:BJP2sWEmIv4KK5OTEluFJCKSidICx8ciO85XgH3Ak8k=

     

       319
       +
       golang.org/x/term v0.0.0-20201126162022-7de9c90e9dd1/go.mod h1:bj7SfCRtBDWHUb9snDiAeCFNEtKQo2Wmx5Cou7ajbmo=

     

       320
       +
       golang.org/x/text v0.3.0/go.mod h1:NqM8EUOU14njkJ3fqMW+pc6Ldnwhi/IjpwHt7yyuwOQ=

     

       321
       +
       golang.org/x/text v0.3.3/go.mod h1:5Zoc/QRtKVWzQhOtBMvqHzDpF6irO9z98xDceosuGiQ=

     

       322
       +
       golang.org/x/time v0.3.0 h1:rg5rLMjNzMS1RkNLzCG38eapWhnYLFYXDXj2gOlr8j4=

     

       323
       +
       golang.org/x/time v0.3.0/go.mod h1:tRJNPiyCQ0inRvYxbN9jk5I+vvW/OXSQhTDSoE431IQ=

     

       324
       +
       golang.org/x/tools v0.0.0-20180917221912-90fa682c2a6e/go.mod h1:n7NCudcB/nEzxVGmLbDWY5pfWTLqBcC2KZ6jyYvM4mQ=

     

       325
       +
       golang.org/x/tools v0.0.0-20190311212946-11955173bddd/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=

     

       326
       +
       golang.org/x/tools v0.0.0-20190328211700-ab21143f2384/go.mod h1:LCzVGOaR6xXOjkQ3onu1FJEFr0SW1gC7cKk1uF8kGRs=

     

       327
       +
       golang.org/x/tools v0.0.0-20190621195816-6e04913cbbac/go.mod h1:/rFqwRUd4F7ZHNgwSSTFct+R/Kf4OFW1sUzUTQQTgfc=

     

       328
       +
       golang.org/x/tools v0.0.0-20191029041327-9cc4af7d6b2c/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=

     

       329
       +
       golang.org/x/tools v0.0.0-20191029190741-b9c20aec41a5/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=

     

       330
       +
       golang.org/x/tools v0.0.0-20191119224855-298f0cb1881e/go.mod h1:b+2E5dAYhXwXZwtnZ6UAqBI28+e2cm9otk0dWdXHAEo=

     

       331
       +
       golang.org/x/tools v0.0.0-20200619180055-7c47624df98f/go.mod h1:EkVYQZoAsY45+roYkvgYkIh4xh/qjgUK9TdY2XT94GE=

     

       332
       +
       golang.org/x/tools v0.0.0-20210106214847-113979e3529a/go.mod h1:emZCQorbCU4vsT4fOWvOPXz4eW1wZW4PmDk9uLelYpA=

     

       333
       +
       golang.org/x/tools v0.1.5/go.mod h1:o0xws9oXOQQZyjljx8fwUC0k7L1pTE6eaCbjGeHmOkk=

     

       334
       +
       golang.org/x/tools v0.33.0 h1:4qz2S3zmRxbGIhDIAgjxvFutSvH5EfnsYrRBj0UI0bc=

     

       335
       +
       golang.org/x/tools v0.33.0/go.mod h1:CIJMaWEY88juyUfo7UbgPqbC8rU2OqfAV1h2Qp0oMYI=

     

       336
       +
       golang.org/x/xerrors v0.0.0-20190717185122-a985d3407aa7/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=

     

       337
       +
       golang.org/x/xerrors v0.0.0-20191011141410-1b5146add898/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=

     

       338
       +
       golang.org/x/xerrors v0.0.0-20191204190536-9bdfabe68543/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=

     

       339
       +
       golang.org/x/xerrors v0.0.0-20200804184101-5ec99f83aff1/go.mod h1:I/5z698sn9Ka8TeJc9MKroUUfqBBauWjQqLJ2OPfmY0=

     

       340
       +
       golang.org/x/xerrors v0.0.0-20231012003039-104605ab7028 h1:+cNy6SZtPcJQH3LJVLOSmiC7MMxXNOb3PU/VUEz+EhU=

     

       341
       +
       golang.org/x/xerrors v0.0.0-20231012003039-104605ab7028/go.mod h1:NDW/Ps6MPRej6fsCIbMTohpP40sJ/P/vI1MoTEGwX90=

     

       342
       +
       google.golang.org/protobuf v1.33.0 h1:uNO2rsAINq/JlFpSdYEKIZ0uKD/R9cpdv0T+yoGwGmI=

     

       343
       +
       google.golang.org/protobuf v1.33.0/go.mod h1:c6P6GXX6sHbq/GpV6MGZEdwhWPcYBgnhAHhKbcUYpos=

     

       344
       +
       gopkg.in/check.v1 v0.0.0-20161208181325-20d25e280405/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=

     

       345
       +
       gopkg.in/check.v1 v1.0.0-20180628173108-788fd7840127/go.mod h1:Co6ibVJAznAaIkqp8huTwlJQCZ016jof/cbN4VW5Yz0=

     

       346
       +
       gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c h1:Hei/4ADfdWqJk1ZMxUNpqntNwaWcugrBjAiHlqqRiVk=

     

       347
       +
       gopkg.in/check.v1 v1.0.0-20201130134442-10cb98267c6c/go.mod h1:JHkPIbrfpd72SG/EVd6muEfDQjcINNoR0C8j2r3qZ4Q=

     

       348
       +
       gopkg.in/errgo.v2 v2.1.0/go.mod h1:hNsd1EY+bozCKY1Ytp96fpM3vjJbqLJn88ws8XvfDNI=

     

       349
       +
       gopkg.in/yaml.v2 v2.2.2/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=

     

       350
       +
       gopkg.in/yaml.v2 v2.2.8/go.mod h1:hI93XBmqTisBFMUTm0b8Fm+jr3Dg1NNxqwp+5A1VGuI=

     

       351
       +
       gopkg.in/yaml.v2 v2.4.0 h1:D8xgwECY7CYvx+Y2n4sBz93Jn9JRvxdiyyo8CTfuKaY=

     

       352
       +
       gopkg.in/yaml.v2 v2.4.0/go.mod h1:RDklbk79AGWmwhnvt/jBztapEOGDOx6ZbXqjP6csGnQ=

     

       353
       +
       gopkg.in/yaml.v3 v3.0.0-20200313102051-9f266ea9e77c/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

     

       354
       +
       gopkg.in/yaml.v3 v3.0.0-20210107192922-496545a6307b/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

     

       355
       +
       gopkg.in/yaml.v3 v3.0.1 h1:fxVm/GzAzEWqLHuvctI91KS9hhNmmWOoWu0XTYJS7CA=

     

       356
       +
       gopkg.in/yaml.v3 v3.0.1/go.mod h1:K4uyk7z7BCEPqu6E+C64Yfv1cQ7kz7rIZviUmN+EgEM=

     

       357
       +
       honnef.co/go/tools v0.0.1-2019.2.3/go.mod h1:a3bituU0lyd329TUQxRnasdCoJDkEUEAqEt0JzvZhAg=

     

       358
       +
       lukechampine.com/blake3 v1.2.1 h1:YuqqRuaqsGV71BV/nm9xlI0MKUv4QC54jQnBChWbGnI=

     

       359
       +
       lukechampine.com/blake3 v1.2.1/go.mod h1:0OFRp7fBtAylGVCO40o87sbupkyIGgbpv1+M1k1LM6k=

     

       360
       +
       modernc.org/cc/v4 v4.26.1 h1:+X5NtzVBn0KgsBCBe+xkDC7twLb/jNVj9FPgiwSQO3s=

     

       361
       +
       modernc.org/cc/v4 v4.26.1/go.mod h1:uVtb5OGqUKpoLWhqwNQo/8LwvoiEBLvZXIQ/SmO6mL0=

     

       362
       +
       modernc.org/ccgo/v4 v4.28.0 h1:rjznn6WWehKq7dG4JtLRKxb52Ecv8OUGah8+Z/SfpNU=

     

       363
       +
       modernc.org/ccgo/v4 v4.28.0/go.mod h1:JygV3+9AV6SmPhDasu4JgquwU81XAKLd3OKTUDNOiKE=

     

       364
       +
       modernc.org/fileutil v1.3.1 h1:8vq5fe7jdtEvoCf3Zf9Nm0Q05sH6kGx0Op2CPx1wTC8=

     

       365
       +
       modernc.org/fileutil v1.3.1/go.mod h1:HxmghZSZVAz/LXcMNwZPA/DRrQZEVP9VX0V4LQGQFOc=

     

       366
       +
       modernc.org/gc/v2 v2.6.5 h1:nyqdV8q46KvTpZlsw66kWqwXRHdjIlJOhG6kxiV/9xI=

     

       367
       +
       modernc.org/gc/v2 v2.6.5/go.mod h1:YgIahr1ypgfe7chRuJi2gD7DBQiKSLMPgBQe9oIiito=

     

       368
       +
       modernc.org/libc v1.65.7 h1:Ia9Z4yzZtWNtUIuiPuQ7Qf7kxYrxP1/jeHZzG8bFu00=

     

       369
       +
       modernc.org/libc v1.65.7/go.mod h1:011EQibzzio/VX3ygj1qGFt5kMjP0lHb0qCW5/D/pQU=

     

       370
       +
       modernc.org/mathutil v1.7.1 h1:GCZVGXdaN8gTqB1Mf/usp1Y/hSqgI2vAGGP4jZMCxOU=

     

       371
       +
       modernc.org/mathutil v1.7.1/go.mod h1:4p5IwJITfppl0G4sUEDtCr4DthTaT47/N3aT6MhfgJg=

     

       372
       +
       modernc.org/memory v1.11.0 h1:o4QC8aMQzmcwCK3t3Ux/ZHmwFPzE6hf2Y5LbkRs+hbI=

     

       373
       +
       modernc.org/memory v1.11.0/go.mod h1:/JP4VbVC+K5sU2wZi9bHoq2MAkCnrt2r98UGeSK7Mjw=

     

       374
       +
       modernc.org/opt v0.1.4 h1:2kNGMRiUjrp4LcaPuLY2PzUfqM/w9N23quVwhKt5Qm8=

     

       375
       +
       modernc.org/opt v0.1.4/go.mod h1:03fq9lsNfvkYSfxrfUhZCWPk1lm4cq4N+Bh//bEtgns=

     

       376
       +
       modernc.org/sortutil v1.2.1 h1:+xyoGf15mM3NMlPDnFqrteY07klSFxLElE2PVuWIJ7w=

     

       377
       +
       modernc.org/sortutil v1.2.1/go.mod h1:7ZI3a3REbai7gzCLcotuw9AC4VZVpYMjDzETGsSMqJE=

     

       378
       +
       modernc.org/sqlite v1.37.1 h1:EgHJK/FPoqC+q2YBXg7fUmES37pCHFc97sI7zSayBEs=

     

       379
       +
       modernc.org/sqlite v1.37.1/go.mod h1:XwdRtsE1MpiBcL54+MbKcaDvcuej+IYSMfLN6gSKV8g=

     

       380
       +
       modernc.org/strutil v1.2.1 h1:UneZBkQA+DX2Rp35KcM69cSsNES9ly8mQWD71HKlOA0=

     

       381
       +
       modernc.org/strutil v1.2.1/go.mod h1:EHkiggD70koQxjVdSBM3JKM7k6L0FbGE5eymy9i3B9A=

     

       382
       +
       modernc.org/token v1.1.0 h1:Xl7Ap9dKaEs5kLoOQeQmPWevfnk/DM5qcLcYlA8ys6Y=

     

       383
       +
       modernc.org/token v1.1.0/go.mod h1:UGzOrNV1mAFSEB63lOFHIpNRUVMvYTc6yu1SMY/XTDM=

+81

src/firehose-consumer.go

···

       1
       +
       package main

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"fmt"

     

       5
       +
       	"log"

     

       6
       +
       	"net/url"

     

       7
       +
       	"time"

     

       8
       +
       

     

       9
       +
       	"github.com/gorilla/websocket"

     

       10
       +
       )

     

       11
       +
       

     

       12
       +
       const FIREHOSE_QUERY = "wantedCollections=app.bsky.feed.post"

     

       13
       +
       

     

       14
       +
       const URL_RELAY_JETSTREAM2 = "wss://jetstream2.us-east.bsky.network/subscribe"

     

       15
       +
       const URL_RELAY_BLACKSKY = "wss://atproto.africa/xrpc/com.atproto.sync.subscribeRepos"

     

       16
       +
       

     

       17
       +
       type OnMessageCB = func(message []byte)

     

       18
       +
       

     

       19
       +
       type FirehoseConsumer struct {

     

       20
       +
       	WebsocketConnection *websocket.Conn

     

       21
       +
       	MessagesChan        *chan []byte

     

       22
       +
       	DoneSignal          *chan struct{}

     

       23
       +
       }

     

       24
       +
       

     

       25
       +
       func MakeConsumer(baseUrl string) *FirehoseConsumer {

     

       26
       +
       	firehoseUrl, err := url.Parse(fmt.Sprintf("%s?%s", baseUrl, FIREHOSE_QUERY))

     

       27
       +
       

     

       28
       +
       	MessagesChan := make(chan []byte)

     

       29
       +
       	doneSignal := make(chan struct{})

     

       30
       +
       	conn, _, err := websocket.DefaultDialer.Dial(firehoseUrl.String(), nil)

     

       31
       +
       	if err != nil {

     

       32
       +
       		log.Fatal("failed to dial: ", err)

     

       33
       +
       	}

     

       34
       +
       

     

       35
       +
       	consumer := FirehoseConsumer{

     

       36
       +
       		WebsocketConnection: conn,

     

       37
       +
       		MessagesChan:        &MessagesChan,

     

       38
       +
       		DoneSignal:          &doneSignal,

     

       39
       +
       	}

     

       40
       +
       

     

       41
       +
       	return &consumer

     

       42
       +
       }

     

       43
       +
       

     

       44
       +
       func (consumer *FirehoseConsumer) Close() error {

     

       45
       +
       	return consumer.WebsocketConnection.Close()

     

       46
       +
       }

     

       47
       +
       

     

       48
       +
       func (consumer *FirehoseConsumer) StartConsumer() {

     

       49
       +
       	defer close(*consumer.DoneSignal)

     

       50
       +
       	for {

     

       51
       +
       		_, message, err := consumer.WebsocketConnection.ReadMessage()

     

       52
       +
       		if err != nil {

     

       53
       +
       			log.Println(err)

     

       54
       +
       			return

     

       55
       +
       		}

     

       56
       +
       

     

       57
       +
       		// onMessage(message)

     

       58
       +
       		*consumer.MessagesChan <- message

     

       59
       +
       	}

     

       60
       +
       }

     

       61
       +
       

     

       62
       +
       func (consumer *FirehoseConsumer) CloseWithTimeout(timeoutDuration time.Duration) error {

     

       63
       +
       	err := consumer.WebsocketConnection.WriteMessage(

     

       64
       +
       		websocket.CloseMessage,

     

       65
       +
       		websocket.FormatCloseMessage(

     

       66
       +
       			websocket.CloseNormalClosure,

     

       67
       +
       			"",

     

       68
       +
       		),

     

       69
       +
       	)

     

       70
       +
       

     

       71
       +
       	if err != nil {

     

       72
       +
       		return fmt.Errorf("failed to close ws: ", err)

     

       73
       +
       	}

     

       74
       +
       

     

       75
       +
       	select {

     

       76
       +
       	case <-*consumer.DoneSignal:

     

       77
       +
       		return nil

     

       78
       +
       	case <-time.After(timeoutDuration):

     

       79
       +
       		return fmt.Errorf("websocket close timeout")

     

       80
       +
       	}

     

       81
       +
       }

+222

src/firehose-decoders.go

···

       1
       +
       package main

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"bytes"

     

       5
       +
       	"context"

     

       6
       +
       	"encoding/json"

     

       7
       +
       	"fmt"

     

       8
       +
       	"io"

     

       9
       +
       	"log"

     

       10
       +
       	"net/http"

     

       11
       +
       	"os"

     

       12
       +
       	"strings"

     

       13
       +
       	"time"

     

       14
       +
       

     

       15
       +
       	"github.com/bluesky-social/indigo/repo"

     

       16
       +
       	"github.com/fxamacker/cbor/v2"

     

       17
       +
       	"github.com/ipfs/go-cid"

     

       18
       +
       )

     

       19
       +
       

     

       20
       +
       func JSONDecoder(messageChan chan *DatabasePost) OnMessageCB {

     

       21
       +
       	return func(message []byte) {

     

       22
       +
       

     

       23
       +
       		// log.Printf("recv: %s", message)

     

       24
       +
       

     

       25
       +
       		var data ComBskyFeedPost

     

       26
       +
       		err := json.Unmarshal(message, &data)

     

       27
       +
       		if err != nil {

     

       28
       +
       			log.Println(fmt.Errorf("failed to unmarshal data", err))

     

       29
       +
       			return

     

       30
       +
       		}

     

       31
       +
       

     

       32
       +
       		// log.Printf("parse: %s", data)

     

       33
       +
       

     

       34
       +
       		/// /// /// /// /// /// /// ///

     

       35
       +
       		/// Begin Filtering Logic   ///

     

       36
       +
       		/// /// /// /// /// /// /// ///

     

       37
       +
       

     

       38
       +
       		if data.Commit.Operation != "create" {

     

       39
       +
       			return

     

       40
       +
       		}

     

       41
       +
       

     

       42
       +
       		topic := "unknown"

     

       43
       +
       		text := data.Commit.Record.Text

     

       44
       +
       		if MessageIsAboutCoffee(text) {

     

       45
       +
       			topic = "coffee"

     

       46
       +
       		} else if MessageSlippedOnBananaPeel(text) {

     

       47
       +
       			topic = "banana-slip"

     

       48
       +
       		} else {

     

       49
       +
       			return

     

       50
       +
       		}

     

       51
       +
       

     

       52
       +
       		/// /// /// /// /// /// /// ///

     

       53
       +
       		/// End Filtering Logic     ///

     

       54
       +
       		/// /// /// /// /// /// /// ///

     

       55
       +
       

     

       56
       +
       		log.Printf("text (topic=%s): %s", topic, text)

     

       57
       +
       

     

       58
       +
       		uri := fmt.Sprintf("at://%s/%s/%s", data.Did, data.Commit.Collection, data.Commit.Rev)

     

       59
       +
       		cid := data.Commit.Cid

     

       60
       +
       

     

       61
       +
       		now := time.Now()

     

       62
       +
       		indexedAt := now.UTC().Format(time.RFC3339)

     

       63
       +
       

     

       64
       +
       		post := &DatabasePost{

     

       65
       +
       			Uri:       uri,

     

       66
       +
       			Cid:       cid,

     

       67
       +
       			Topic:     topic,

     

       68
       +
       			IndexedAt: indexedAt,

     

       69
       +
       		}

     

       70
       +
       

     

       71
       +
       		// log.Printf("formed: %s", post)

     

       72
       +
       		messageChan <- post

     

       73
       +
       	}

     

       74
       +
       }

     

       75
       +
       

     

       76
       +
       func CBORDecoder(messageChan chan *DatabasePost) OnMessageCB {

     

       77
       +
       	return func(message []byte) {

     

       78
       +
       		var frame MessageFrameCBOR

     

       79
       +
       		var err error

     

       80
       +
       

     

       81
       +
       		remaining, err := cbor.UnmarshalFirst(message, &frame.Header)

     

       82
       +
       		if err != nil {

     

       83
       +
       			log.Println(fmt.Errorf("failed to unmarshal frame header data", err))

     

       84
       +
       			return

     

       85
       +
       		}

     

       86
       +
       

     

       87
       +
       		if frame.Header.Kind != "#commit" {

     

       88
       +
       			return

     

       89
       +
       		}

     

       90
       +
       

     

       91
       +
       		_, err = cbor.UnmarshalFirst(remaining, &frame.Commit)

     

       92
       +
       		if err != nil {

     

       93
       +
       			log.Println(fmt.Errorf("failed to unmarshal frame body as commit", err))

     

       94
       +
       			return

     

       95
       +
       		}

     

       96
       +
       

     

       97
       +
       		var car *repo.Repo = nil

     

       98
       +
       		var ctx *context.Context = nil

     

       99
       +
       		for _, op := range frame.Commit.Ops {

     

       100
       +
       			if op.Action != "create" || !strings.Contains(op.Path, "app.bsky.feed.post/") {

     

       101
       +
       				continue

     

       102
       +
       			}

     

       103
       +
       

     

       104
       +
       			// Why do we need to remove the first character? No idea, but it's garbage

     

       105
       +
       			opCID, err := cid.Cast(op.RawCID[1:])

     

       106
       +
       			if err != nil {

     

       107
       +
       				log.Println(fmt.Errorf("failed to unmarshal CID: ", err))

     

       108
       +
       				return

     

       109
       +
       			}

     

       110
       +
       

     

       111
       +
       			if car == nil {

     

       112
       +
       				blocks := bytes.NewReader(frame.Commit.Blocks)

     

       113
       +
       				newCtx := context.Background()

     

       114
       +
       				ctx = &newCtx

     

       115
       +
       				car, err = repo.ReadRepoFromCar(*ctx, blocks)

     

       116
       +
       				if err != nil {

     

       117
       +
       					log.Println(fmt.Errorf("failed to read CAR: ", err))

     

       118
       +
       					return

     

       119
       +
       				}

     

       120
       +
       			}

     

       121
       +
       

     

       122
       +
       			block, err := car.Blockstore().Get(*ctx, opCID)

     

       123
       +
       			if err != nil {

     

       124
       +
       				log.Println(fmt.Errorf("failed to retrieve from blockstore: ", err))

     

       125
       +
       				return

     

       126
       +
       			}

     

       127
       +
       

     

       128
       +
       			rawData := block.RawData()

     

       129
       +
       			var blockData BlockCBOR

     

       130
       +
       			_, err = cbor.UnmarshalFirst(rawData, &blockData)

     

       131
       +
       			if err != nil {

     

       132
       +
       				log.Println(fmt.Errorf("failed to unmarshall block data: ", err))

     

       133
       +
       				return

     

       134
       +
       			}

     

       135
       +
       

     

       136
       +
       			embedKind := blockData.Embed.Kind

     

       137
       +
       			if embedKind == "app.bsky.embed.images" && strings.Contains(strings.ToLower(blockData.Text), "coffee") {

     

       138
       +
       				for _, imageData := range blockData.Embed.Images {

     

       139
       +
       					// Why do we need to remove the first character? No idea, but it's garbage

     

       140
       +
       					imageCID, err := cid.Cast(imageData.Image.Ref[1:])

     

       141
       +
       					if err != nil {

     

       142
       +
       						log.Println(fmt.Errorf("failed to unmarshal image CID: ", err))

     

       143
       +
       						return

     

       144
       +
       					}

     

       145
       +
       

     

       146
       +
       					// what do we do with imageCID???

     

       147
       +
       					imageCDNURL := fmt.Sprintf(

     

       148
       +
       						"https://cdn.bsky.app/img/feed_thumbnail/plain/%s/%s",

     

       149
       +
       						frame.Commit.Did,

     

       150
       +
       						imageCID.String(),

     

       151
       +
       					)

     

       152
       +
       

     

       153
       +
       					res, err := http.Get(imageCDNURL)

     

       154
       +
       					if err != nil {

     

       155
       +
       						log.Println(fmt.Errorf("failed to download image: ", err))

     

       156
       +
       						return

     

       157
       +
       					}

     

       158
       +
       

     

       159
       +
       					defer res.Body.Close()

     

       160
       +
       					// body, err := io.ReadAll(res.Body)

     

       161
       +
       					// if err != nil {

     

       162
       +
       					// 	log.Println(fmt.Errorf("failed to read image: ", err))

     

       163
       +
       					// 	return

     

       164
       +
       					// }

     

       165
       +
       

     

       166
       +
       					file, err := os.Create(fmt.Sprintf("im/%s-%s.jpeg", frame.Commit.Did, imageCID.String()))

     

       167
       +
       					if err != nil {

     

       168
       +
       						log.Println(fmt.Errorf("failed to open image file: ", err))

     

       169
       +
       						return

     

       170
       +
       					}

     

       171
       +
       					defer file.Close()

     

       172
       +
       

     

       173
       +
       					_, err = io.Copy(file, res.Body)

     

       174
       +
       					if err != nil {

     

       175
       +
       						log.Println(fmt.Errorf("failed to copy to image file: ", err))

     

       176
       +
       						return

     

       177
       +
       					}

     

       178
       +
       				}

     

       179
       +
       			}

     

       180
       +
       

     

       181
       +
       			// FINALLY

     

       182
       +
       			text := blockData.Text

     

       183
       +
       

     

       184
       +
       			/// /// /// /// /// /// /// ///

     

       185
       +
       			/// Begin Filtering Logic   ///

     

       186
       +
       			/// /// /// /// /// /// /// ///

     

       187
       +
       

     

       188
       +
       			topic := "unknown"

     

       189
       +
       			if MessageIsAboutCoffee(text) {

     

       190
       +
       				topic = "coffee"

     

       191
       +
       			} else if MessageSlippedOnBananaPeel(text) {

     

       192
       +
       				topic = "banana-slip"

     

       193
       +
       			} else {

     

       194
       +
       				return

     

       195
       +
       			}

     

       196
       +
       

     

       197
       +
       			/// /// /// /// /// /// /// ///

     

       198
       +
       			/// End Filtering Logic     ///

     

       199
       +
       			/// /// /// /// /// /// /// ///

     

       200
       +
       

     

       201
       +
       			log.Printf("text (topic=%s): %s", topic, text)

     

       202
       +
       

     

       203
       +
       			did := frame.Commit.Did

     

       204
       +
       			path := op.Path

     

       205
       +
       

     

       206
       +
       			uri := fmt.Sprintf("at://%s/%s", did, path)

     

       207
       +
       

     

       208
       +
       			now := time.Now()

     

       209
       +
       			indexedAt := now.UTC().Format(time.RFC3339)

     

       210
       +
       

     

       211
       +
       			post := &DatabasePost{

     

       212
       +
       				Uri:       uri,

     

       213
       +
       				Cid:       opCID.String(),

     

       214
       +
       				Topic:     topic,

     

       215
       +
       				IndexedAt: indexedAt,

     

       216
       +
       			}

     

       217
       +
       

     

       218
       +
       			// log.Printf("formed: %s", post)

     

       219
       +
       			messageChan <- post

     

       220
       +
       		}

     

       221
       +
       	}

     

       222
       +
       }

+232

src/http-server.go

···

       1
       +
       package main

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"encoding/json"

     

       5
       +
       	"fmt"

     

       6
       +
       	"log"

     

       7
       +
       	"net/http"

     

       8
       +
       	"strconv"

     

       9
       +
       	"strings"

     

       10
       +
       	"time"

     

       11
       +
       

     

       12
       +
       	combskytypes "github.com/bluesky-social/indigo/api/bsky"

     

       13
       +
       	chi "github.com/go-chi/chi/v5"

     

       14
       +
       	middleware "github.com/go-chi/chi/v5/middleware"

     

       15
       +
       )

     

       16
       +
       

     

       17
       +
       type HTTPServerSettings struct {

     

       18
       +
       	PublisherDID string

     

       19
       +
       	ServiceDID   string

     

       20
       +
       	Hostname     string

     

       21
       +
       }

     

       22
       +
       

     

       23
       +
       type HTTPServer struct {

     

       24
       +
       	Router       chi.Router

     

       25
       +
       	DatabaseConn *ManagedDatabaseConnection

     

       26
       +
       	DoneSignal   *chan interface{}

     

       27
       +
       	Settings     HTTPServerSettings

     

       28
       +
       }

     

       29
       +
       

     

       30
       +
       func NewHTTPServer(dbcon *ManagedDatabaseConnection) *HTTPServer {

     

       31
       +
       	router := chi.NewRouter()

     

       32
       +
       

     

       33
       +
       	router.Use(middleware.RequestID)

     

       34
       +
       	router.Use(middleware.Logger)

     

       35
       +
       	router.Use(middleware.Recoverer)

     

       36
       +
       	router.Use(middleware.Compress(5))

     

       37
       +
       	router.Use(middleware.SetHeader("Content-Type", "application/json"))

     

       38
       +
       

     

       39
       +
       	env := GetEnvironmentVariables()

     

       40
       +
       	publisherDid := env["FEEDGEN_PUBLISHER_DID"]

     

       41
       +
       	hostname := env["FEEDGEN_HOSTNAME"]

     

       42
       +
       	serviceDid, hasSvcDid := env["FEEDGEN_SERVICE_DID"]

     

       43
       +
       	if !hasSvcDid {

     

       44
       +
       		serviceDid = fmt.Sprintf("did:web:%s", hostname)

     

       45
       +
       	}

     

       46
       +
       

     

       47
       +
       	done := make(chan interface{})

     

       48
       +
       

     

       49
       +
       	server := HTTPServer{

     

       50
       +
       		router,

     

       51
       +
       		dbcon,

     

       52
       +
       		&done,

     

       53
       +
       		HTTPServerSettings{

     

       54
       +
       			publisherDid,

     

       55
       +
       			serviceDid,

     

       56
       +
       			hostname,

     

       57
       +
       		},

     

       58
       +
       	}

     

       59
       +
       

     

       60
       +
       	return &server

     

       61
       +
       }

     

       62
       +
       

     

       63
       +
       func (httpServer HTTPServer) RegisterRoutes() {

     

       64
       +
       	httpServer.Router.Get("/", func(w http.ResponseWriter, r *http.Request) {

     

       65
       +
       		encoded, _ := json.Marshal(

     

       66
       +
       			map[string]interface{}{

     

       67
       +
       				"what": "atproto feed generator, written in from scratch in go",

     

       68
       +
       				"when": "may 2025",

     

       69
       +
       				"who": map[string]string{

     

       70
       +
       					"did":    fmt.Sprintf("at://%s", httpServer.Settings.PublisherDID),

     

       71
       +
       					"github": "https://github.com/keaysma",

     

       72
       +
       				},

     

       73
       +
       			},

     

       74
       +
       		)

     

       75
       +
       

     

       76
       +
       		w.WriteHeader(http.StatusOK)

     

       77
       +
       		w.Write(encoded)

     

       78
       +
       	})

     

       79
       +
       

     

       80
       +
       	httpServer.Router.Get("/.well-known/did.json", func(w http.ResponseWriter, r *http.Request) {

     

       81
       +
       		if !strings.HasSuffix(httpServer.Settings.ServiceDID, httpServer.Settings.Hostname) {

     

       82
       +
       			w.WriteHeader(http.StatusNotFound)

     

       83
       +
       			return

     

       84
       +
       		}

     

       85
       +
       

     

       86
       +
       		encoded, _ := json.Marshal(

     

       87
       +
       			map[string]interface{}{

     

       88
       +
       				"@context": []string{"https://www.w3.org/ns/did/v1"},

     

       89
       +
       				"id":       httpServer.Settings.ServiceDID,

     

       90
       +
       				"service": []map[string]string{

     

       91
       +
       					map[string]string{

     

       92
       +
       						"id":              "#bsky_fg",

     

       93
       +
       						"type":            "BskyFeedGenerator",

     

       94
       +
       						"serviceEndpoint": fmt.Sprintf("https://%s", httpServer.Settings.Hostname),

     

       95
       +
       					},

     

       96
       +
       				},

     

       97
       +
       			},

     

       98
       +
       		)

     

       99
       +
       		w.WriteHeader(http.StatusOK)

     

       100
       +
       		w.Write(encoded)

     

       101
       +
       		return

     

       102
       +
       	})

     

       103
       +
       

     

       104
       +
       	// TBD - Does Indigo provide some kind-of wrapper for this?

     

       105
       +
       	httpServer.Router.Get("/xrpc/app.bsky.feed.getFeedSkeleton", func(w http.ResponseWriter, r *http.Request) {

     

       106
       +
       		query := r.URL.Query()

     

       107
       +
       		feedName := query.Get("feed")

     

       108
       +
       		cursor := query.Get("cursor")

     

       109
       +
       		paramLimit := query.Get("limit")

     

       110
       +
       

     

       111
       +
       		feedNameBase := fmt.Sprintf("at://%s/app.bsky.feed.generator/", httpServer.Settings.PublisherDID)

     

       112
       +
       		algo, hasFeedNameBase := strings.CutPrefix(feedName, feedNameBase)

     

       113
       +
       		if !hasFeedNameBase {

     

       114
       +
       			encoded, _ := json.Marshal(

     

       115
       +
       				map[string]string{

     

       116
       +
       					"error":   "UnsupportedAlgorithm",

     

       117
       +
       					"message": "Unsupported algorithm",

     

       118
       +
       				},

     

       119
       +
       			)

     

       120
       +
       

     

       121
       +
       			w.WriteHeader(http.StatusBadRequest)

     

       122
       +
       			w.Write(encoded)

     

       123
       +
       			return

     

       124
       +
       		}

     

       125
       +
       

     

       126
       +
       		switch algo {

     

       127
       +
       		case "banana-slip":

     

       128
       +
       		case "coffee":

     

       129
       +
       			break

     

       130
       +
       		default:

     

       131
       +
       			encoded, _ := json.Marshal(

     

       132
       +
       				map[string]string{

     

       133
       +
       					"error":   "UnsupportedAlgorithm",

     

       134
       +
       					"message": "Unsupported algorithm",

     

       135
       +
       				},

     

       136
       +
       			)

     

       137
       +
       

     

       138
       +
       			w.WriteHeader(http.StatusBadRequest)

     

       139
       +
       			w.Write(encoded)

     

       140
       +
       			return

     

       141
       +
       		}

     

       142
       +
       

     

       143
       +
       		limit, err := strconv.Atoi(paramLimit)

     

       144
       +
       		if err != nil || limit < 1 || limit > 100 {

     

       145
       +
       			limit = 50

     

       146
       +
       		}

     

       147
       +
       

     

       148
       +
       		indexedBefore := time.Now().UTC()

     

       149
       +
       		if cursor != "" {

     

       150
       +
       			epoch, err := strconv.ParseInt(cursor, 10, 64)

     

       151
       +
       			if err != nil {

     

       152
       +
       				encoded, _ := json.Marshal(

     

       153
       +
       					map[string]string{

     

       154
       +
       						"error":   "InvalidRequest",

     

       155
       +
       						"message": "Bad cursor value",

     

       156
       +
       					},

     

       157
       +
       				)

     

       158
       +
       

     

       159
       +
       				w.WriteHeader(http.StatusBadRequest)

     

       160
       +
       				w.Write(encoded)

     

       161
       +
       				return

     

       162
       +
       			}

     

       163
       +
       			indexedBefore = time.Unix(epoch, 0)

     

       164
       +
       		}

     

       165
       +
       

     

       166
       +
       		feedData, err := httpServer.DatabaseConn.ReadPostsFromDatabase(algo, indexedBefore, limit)

     

       167
       +
       		if err != nil {

     

       168
       +
       			log.Println(fmt.Errorf("failed to read posts from database: ", err))

     

       169
       +
       			encoded, _ := json.Marshal(

     

       170
       +
       				map[string]string{

     

       171
       +
       					"error":   "internal server error",

     

       172
       +
       					"message": "Failed to get feed data",

     

       173
       +
       				},

     

       174
       +
       			)

     

       175
       +
       

     

       176
       +
       			w.WriteHeader(http.StatusInternalServerError)

     

       177
       +
       			w.Write(encoded)

     

       178
       +
       			return

     

       179
       +
       		}

     

       180
       +
       

     

       181
       +
       		feed := make([]combskytypes.FeedDefs_SkeletonFeedPost, 0)

     

       182
       +
       		for _, entry := range *feedData {

     

       183
       +
       			feed = append(feed, combskytypes.FeedDefs_SkeletonFeedPost{

     

       184
       +
       				Post: entry.Uri,

     

       185
       +
       			})

     

       186
       +
       		}

     

       187
       +
       

     

       188
       +
       		lastIndexed := indexedBefore

     

       189
       +
       		if len(*feedData) > 0 {

     

       190
       +
       			lastIndexed, err = time.Parse(time.RFC3339, (*feedData)[len(*feedData)-1].IndexedAt)

     

       191
       +
       			if err != nil {

     

       192
       +
       				log.Println(fmt.Errorf("failed to read posts from database: ", err))

     

       193
       +
       				encoded, _ := json.Marshal(

     

       194
       +
       					map[string]string{

     

       195
       +
       						"error":   "internal server error",

     

       196
       +
       						"message": "Failed to get feed data",

     

       197
       +
       					},

     

       198
       +
       				)

     

       199
       +
       

     

       200
       +
       				w.WriteHeader(http.StatusInternalServerError)

     

       201
       +
       				w.Write(encoded)

     

       202
       +
       				return

     

       203
       +
       			}

     

       204
       +
       		}

     

       205
       +
       

     

       206
       +
       		encoded, _ := json.Marshal(

     

       207
       +
       			map[string]interface{}{

     

       208
       +
       				"cursor": strconv.FormatInt(lastIndexed.UTC().Unix(), 10),

     

       209
       +
       				"feed":   feed,

     

       210
       +
       			},

     

       211
       +
       		)

     

       212
       +
       

     

       213
       +
       		w.WriteHeader(http.StatusOK)

     

       214
       +
       		w.Write(encoded)

     

       215
       +
       	})

     

       216
       +
       }

     

       217
       +
       

     

       218
       +
       func (httpServer HTTPServer) StartListener() {

     

       219
       +
       	env := GetEnvironmentVariables()

     

       220
       +
       	host, hostFound := env["FEEDGEN_LISTENHOST"]

     

       221
       +
       	if !hostFound {

     

       222
       +
       		host = "0.0.0.0"

     

       223
       +
       	}

     

       224
       +
       

     

       225
       +
       	port, portFound := env["FEEDGEN_PORT"]

     

       226
       +
       	if !portFound {

     

       227
       +
       		port = "3123"

     

       228
       +
       	}

     

       229
       +
       

     

       230
       +
       	defer close(*httpServer.DoneSignal)

     

       231
       +
       	http.ListenAndServe(fmt.Sprintf("%s:%s", host, port), httpServer.Router)

     

       232
       +
       }

+112

src/main.go

···

       1
       +
       package main

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"fmt"

     

       5
       +
       	"log"

     

       6
       +
       	"os"

     

       7
       +
       	"os/signal"

     

       8
       +
       	"time"

     

       9
       +
       )

     

       10
       +
       

     

       11
       +
       func main() {

     

       12
       +
       	logger := log.Default()

     

       13
       +
       

     

       14
       +
       	logger.Println("Opening DB connection")

     

       15
       +
       	db, err := NewDatabaseConnection()

     

       16
       +
       	if err != nil {

     

       17
       +
       		log.Fatalf("failed to open db: ", err)

     

       18
       +
       	}

     

       19
       +
       

     

       20
       +
       	logger.Println("Ensuring migrations")

     

       21
       +
       	err = db.EnsureMigrations()

     

       22
       +
       	if err != nil {

     

       23
       +
       		log.Fatalf("failed to ensure migrations: ", err)

     

       24
       +
       	}

     

       25
       +
       

     

       26
       +
       	logger.Println("Preparing post chan -> db consumer")

     

       27
       +
       	chanPosts := make(chan *DatabasePost, 1000)

     

       28
       +
       	go db.StreamPostsFromChannel(chanPosts)

     

       29
       +
       

     

       30
       +
       	logger.Println("Installing interrupt handler")

     

       31
       +
       	interrupt := make(chan os.Signal, 1)

     

       32
       +
       	signal.Notify(interrupt, os.Interrupt)

     

       33
       +
       

     

       34
       +
       	/*

     

       35
       +
       		logger.Println("Creating JS2 firehose websocket consumer")

     

       36
       +
       		consumerJS2 := MakeConsumer(URL_RELAY_JETSTREAM2)

     

       37
       +
       		defer consumerJS2.Close()

     

       38
       +
       

     

       39
       +
       		logger.Println("Starting JS2 firehose consumer")

     

       40
       +
       		go consumerJS2.StartConsumer(

     

       41
       +
       			streamPostsToDbCurry(chanPosts),

     

       42
       +
       		)

     

       43
       +
       

     

       44
       +
       		consumer := consumerJS2

     

       45
       +
       	*/

     

       46
       +
       

     

       47
       +
       	logger.Println("Creating Blacksky firehose websocket consumer")

     

       48
       +
       	consumerBlksky := MakeConsumer(URL_RELAY_BLACKSKY)

     

       49
       +
       	defer consumerBlksky.Close()

     

       50
       +
       

     

       51
       +
       	logger.Println("Initiating message handlers")

     

       52
       +
       	go func() {

     

       53
       +
       		decoder := CBORDecoder(chanPosts)

     

       54
       +
       		for {

     

       55
       +
       			select {

     

       56
       +
       			case data := <-*consumerBlksky.MessagesChan:

     

       57
       +
       				decoder(data)

     

       58
       +
       			}

     

       59
       +
       		}

     

       60
       +
       	}()

     

       61
       +
       

     

       62
       +
       	go func() {

     

       63
       +
       		decoder := CBORDecoder(chanPosts)

     

       64
       +
       		for {

     

       65
       +
       			select {

     

       66
       +
       			case data := <-*consumerBlksky.MessagesChan:

     

       67
       +
       				decoder(data)

     

       68
       +
       			}

     

       69
       +
       		}

     

       70
       +
       	}()

     

       71
       +
       

     

       72
       +
       	logger.Println("Starting Blacksky firehose consumer")

     

       73
       +
       	go consumerBlksky.StartConsumer(

     

       74
       +
       	// CBORDecoder(chanPosts),

     

       75
       +
       	)

     

       76
       +
       

     

       77
       +
       	consumer := consumerBlksky

     

       78
       +
       

     

       79
       +
       	logger.Println("Creating HTTP server")

     

       80
       +
       	server := NewHTTPServer(db)

     

       81
       +
       

     

       82
       +
       	logger.Println("Registering routes")

     

       83
       +
       	server.RegisterRoutes()

     

       84
       +
       

     

       85
       +
       	logger.Println("Starting HTTP server")

     

       86
       +
       	go server.StartListener()

     

       87
       +
       

     

       88
       +
       	logger.Println("System is now running until it isn't")

     

       89
       +
       	for {

     

       90
       +
       		select {

     

       91
       +
       		case <-*consumer.DoneSignal:

     

       92
       +
       			logger.Println("ws goroutine closed, goodbye")

     

       93
       +
       			return

     

       94
       +
       		case <-*server.DoneSignal:

     

       95
       +
       			logger.Println("http server closed, goodbye")

     

       96
       +
       			err := consumer.CloseWithTimeout(time.Second)

     

       97
       +
       			if err != nil {

     

       98
       +
       				logger.Println("failed to close ws: ", err)

     

       99
       +
       			}

     

       100
       +
       

     

       101
       +
       			return

     

       102
       +
       		case <-interrupt:

     

       103
       +
       			fmt.Println()

     

       104
       +
       			err := consumer.CloseWithTimeout(time.Second)

     

       105
       +
       			if err != nil {

     

       106
       +
       				logger.Println("failed to close ws: ", err)

     

       107
       +
       			}

     

       108
       +
       

     

       109
       +
       			return

     

       110
       +
       		}

     

       111
       +
       	}

     

       112
       +
       }

+18

src/message-filters.go

···

       1
       +
       package main

     

       2
       +
       

     

       3
       +
       import "strings"

     

       4
       +
       

     

       5
       +
       type MessageFilter = func(rawText string) bool

     

       6
       +
       

     

       7
       +
       func MessageIsAboutCoffee(rawText string) bool {

     

       8
       +
       	textLower := strings.ToLower(rawText)

     

       9
       +
       	thisIsAboutCoffee := strings.Contains(textLower, "coffee") || strings.Contains(textLower, "コーヒー")

     

       10
       +
       	return thisIsAboutCoffee

     

       11
       +
       }

     

       12
       +
       

     

       13
       +
       func MessageSlippedOnBananaPeel(rawText string) bool {

     

       14
       +
       	textLower := strings.ToLower(rawText)

     

       15
       +
       	thisIsAboutCoffee := (strings.Contains(textLower, "banana") ||

     

       16
       +
       		strings.Contains(textLower, "peel"))

     

       17
       +
       	return thisIsAboutCoffee

     

       18
       +
       }

+219

src/sqlite-store.go

···

       1
       +
       package main

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"database/sql"

     

       5
       +
       	"fmt"

     

       6
       +
       	"log"

     

       7
       +
       	"sync"

     

       8
       +
       	"time"

     

       9
       +
       

     

       10
       +
       	// SQLite3 Database Driver

     

       11
       +
       	_ "modernc.org/sqlite"

     

       12
       +
       )

     

       13
       +
       

     

       14
       +
       const DB_DRIVER = "sqlite"

     

       15
       +
       const DB_PATH_DEFAULT = "feed.sqlite"

     

       16
       +
       

     

       17
       +
       type ManagedDatabaseConnection struct {

     

       18
       +
       	db    *sql.DB

     

       19
       +
       	mutex *sync.Mutex

     

       20
       +
       }

     

       21
       +
       

     

       22
       +
       func NewDatabaseConnection() (*ManagedDatabaseConnection, error) {

     

       23
       +
       	env := GetEnvironmentVariables()

     

       24
       +
       	envDBName, isFound := env["FEEDGEN_SQLITE_LOCATION"]

     

       25
       +
       	if !isFound {

     

       26
       +
       		envDBName = DB_PATH_DEFAULT

     

       27
       +
       	}

     

       28
       +
       

     

       29
       +
       	log.Println(fmt.Sprintf("Opening database at %s", envDBName))

     

       30
       +
       	db, err := sql.Open(DB_DRIVER, envDBName)

     

       31
       +
       	if err != nil {

     

       32
       +
       		log.Fatalf("failed to open database connection", err)

     

       33
       +
       		return nil, err

     

       34
       +
       	}

     

       35
       +
       

     

       36
       +
       	mutex := &sync.Mutex{}

     

       37
       +
       

     

       38
       +
       	driver := ManagedDatabaseConnection{

     

       39
       +
       		db,

     

       40
       +
       		mutex,

     

       41
       +
       	}

     

       42
       +
       

     

       43
       +
       	return &driver, nil

     

       44
       +
       }

     

       45
       +
       

     

       46
       +
       func (mdbc *ManagedDatabaseConnection) ensureMigration(desc string, migration func() error) error {

     

       47
       +
       	// If you didn't grab the lock before running this,

     

       48
       +
       	// you're going to have a bad time

     

       49
       +
       

     

       50
       +
       	// If you try to grab the lock within this method,

     

       51
       +
       	// you're going to have a bad time

     

       52
       +
       

     

       53
       +
       	rows, err := mdbc.db.Query(

     

       54
       +
       		"SELECT runAt FROM migration WHERE description = ?",

     

       55
       +
       		desc,

     

       56
       +
       	)

     

       57
       +
       

     

       58
       +
       	if err != nil {

     

       59
       +
       		return err

     

       60
       +
       	}

     

       61
       +
       

     

       62
       +
       	var runAt string = ""

     

       63
       +
       	for rows.Next() {

     

       64
       +
       		err := rows.Scan(&runAt)

     

       65
       +
       		if err != nil {

     

       66
       +
       			return err

     

       67
       +
       		}

     

       68
       +
       	}

     

       69
       +
       

     

       70
       +
       	if runAt != "" {

     

       71
       +
       		log.Println(fmt.Sprintf("migration %s already ran at %s", desc, runAt))

     

       72
       +
       		return nil

     

       73
       +
       	}

     

       74
       +
       

     

       75
       +
       	err = migration()

     

       76
       +
       	if err != nil {

     

       77
       +
       		return err

     

       78
       +
       	}

     

       79
       +
       

     

       80
       +
       	now := time.Now().UTC().Format(time.RFC3339)

     

       81
       +
       	_, err = mdbc.db.Exec(

     

       82
       +
       		"INSERT INTO migration (description, runAt) VALUES (?, ?)",

     

       83
       +
       		desc,

     

       84
       +
       		now,

     

       85
       +
       	)

     

       86
       +
       	if err != nil {

     

       87
       +
       		return err

     

       88
       +
       	}

     

       89
       +
       

     

       90
       +
       	log.Println(fmt.Sprintf("migration %s run at %s", desc, now))

     

       91
       +
       

     

       92
       +
       	return nil

     

       93
       +
       }

     

       94
       +
       

     

       95
       +
       func (mdbc *ManagedDatabaseConnection) EnsureMigrations() error {

     

       96
       +
       	/*

     

       97
       +
       		sqlite> .schema post

     

       98
       +
       		CREATE TABLE IF NOT EXISTS "post" ("uri" varchar primary key, "cid" varchar not null, "indexedAt" varchar not null);

     

       99
       +
       	*/

     

       100
       +
       

     

       101
       +
       	mdbc.mutex.Lock()

     

       102
       +
       	defer mdbc.mutex.Unlock()

     

       103
       +
       

     

       104
       +
       	_, err := mdbc.db.Exec(

     

       105
       +
       		`CREATE TABLE IF NOT EXISTS "migration" ("description" varchar primary key, "runAt" varchar not null);`,

     

       106
       +
       	)

     

       107
       +
       	if err != nil {

     

       108
       +
       		return err

     

       109
       +
       	}

     

       110
       +
       

     

       111
       +
       	err = mdbc.ensureMigration("create posts table", func() error {

     

       112
       +
       		_, err = mdbc.db.Exec(

     

       113
       +
       			`CREATE TABLE IF NOT EXISTS "post" ("uri" varchar primary key, "cid" varchar not null, "indexedAt" varchar not null);`,

     

       114
       +
       		)

     

       115
       +
       		return err

     

       116
       +
       	})

     

       117
       +
       	if err != nil {

     

       118
       +
       		return err

     

       119
       +
       	}

     

       120
       +
       

     

       121
       +
       	err = mdbc.ensureMigration("add topic to posts table", func() error {

     

       122
       +
       		_, err = mdbc.db.Exec(

     

       123
       +
       			`ALTER TABLE post RENAME TO post_old;`,

     

       124
       +
       		)

     

       125
       +
       		if err != nil {

     

       126
       +
       			return err

     

       127
       +
       		}

     

       128
       +
       		_, err = mdbc.db.Exec(

     

       129
       +
       			`CREATE TABLE IF NOT EXISTS "post" ("uri" varchar primary key, "cid" varchar not null, "topic" varchar not null, "indexedAt" varchar not null);`,

     

       130
       +
       		)

     

       131
       +
       		if err != nil {

     

       132
       +
       			return err

     

       133
       +
       		}

     

       134
       +
       		_, err = mdbc.db.Exec(

     

       135
       +
       			`INSERT INTO post (uri, cid, indexedAt, topic) SELECT uri, cid, indexedAt, 'coffee' FROM post_old;`,

     

       136
       +
       		)

     

       137
       +
       		if err != nil {

     

       138
       +
       			return err

     

       139
       +
       		}

     

       140
       +
       

     

       141
       +
       		_, err = mdbc.db.Exec(

     

       142
       +
       			`DROP TABLE post_old;`,

     

       143
       +
       		)

     

       144
       +
       		return err

     

       145
       +
       	})

     

       146
       +
       	if err != nil {

     

       147
       +
       		return err

     

       148
       +
       	}

     

       149
       +
       

     

       150
       +
       	return err

     

       151
       +
       }

     

       152
       +
       

     

       153
       +
       func (mdbc *ManagedDatabaseConnection) WriteToPostTable(payload *DatabasePost) error {

     

       154
       +
       	/*

     

       155
       +
       		sqlite> INSERT INTO post (uri, cid, indexedAt) VALUES ('test', 'test', '2025-05-24T16:33:53.960Z');

     

       156
       +
       		sqlite>

     

       157
       +
       		sqlite> SELECT * FROM post WHERE uri = 'test';

     

       158
       +
       		test|test|2025-05-24T16:33:53.960Z

     

       159
       +
       	*/

     

       160
       +
       

     

       161
       +
       	mdbc.mutex.Lock()

     

       162
       +
       	defer mdbc.mutex.Unlock()

     

       163
       +
       

     

       164
       +
       	stmt, err := mdbc.db.Prepare("INSERT INTO post (uri, cid, topic, indexedAt) VALUES (?, ?, ?, ?)")

     

       165
       +
       	if err != nil {

     

       166
       +
       		return err

     

       167
       +
       	}

     

       168
       +
       	defer stmt.Close()

     

       169
       +
       

     

       170
       +
       	_, err = stmt.Exec(payload.Uri, payload.Cid, payload.Topic, payload.IndexedAt)

     

       171
       +
       

     

       172
       +
       	return err

     

       173
       +
       }

     

       174
       +
       

     

       175
       +
       func (mdbc *ManagedDatabaseConnection) StreamPostsFromChannel(postsChannel chan *DatabasePost) {

     

       176
       +
       	defer close(postsChannel)

     

       177
       +
       	for {

     

       178
       +
       		select {

     

       179
       +
       		case post := <-postsChannel:

     

       180
       +
       			err := mdbc.WriteToPostTable(post)

     

       181
       +
       			if err != nil {

     

       182
       +
       				log.Fatalf("failed to write post: ", err)

     

       183
       +
       			}

     

       184
       +
       		}

     

       185
       +
       	}

     

       186
       +
       }

     

       187
       +
       

     

       188
       +
       func (mdbc *ManagedDatabaseConnection) ReadPostsFromDatabase(topic string, indexedBefore time.Time, limit int) (*[]DatabasePost, error) {

     

       189
       +
       	/*

     

       190
       +
       		SELECT uri, cid, indexedAt FROM post WHERE indexedAt < '2026' ORDER BY indexedAt DESC, cid DESC;

     

       191
       +
       	*/

     

       192
       +
       

     

       193
       +
       	mdbc.mutex.Lock()

     

       194
       +
       	defer mdbc.mutex.Unlock()

     

       195
       +
       

     

       196
       +
       	rows, err := mdbc.db.Query(

     

       197
       +
       		"SELECT uri, cid, indexedAt FROM post WHERE topic = ? AND indexedAt < ? ORDER BY indexedAt DESC, cid DESC LIMIT ?",

     

       198
       +
       		topic,

     

       199
       +
       		indexedBefore.Format(time.RFC3339),

     

       200
       +
       		limit,

     

       201
       +
       	)

     

       202
       +
       

     

       203
       +
       	if err != nil {

     

       204
       +
       		return nil, err

     

       205
       +
       	}

     

       206
       +
       

     

       207
       +
       	posts := make([]DatabasePost, 0)

     

       208
       +
       	for rows.Next() {

     

       209
       +
       		var post DatabasePost

     

       210
       +
       		err := rows.Scan(&post.Uri, &post.Cid, &post.IndexedAt)

     

       211
       +
       		if err != nil {

     

       212
       +
       			return nil, err

     

       213
       +
       		}

     

       214
       +
       

     

       215
       +
       		posts = append(posts, post)

     

       216
       +
       	}

     

       217
       +
       

     

       218
       +
       	return &posts, nil

     

       219
       +
       }

+77

src/types.go

···

       1
       +
       package main

     

       2
       +
       

     

       3
       +
       type DatabasePost struct {

     

       4
       +
       	Uri       string

     

       5
       +
       	Cid       string

     

       6
       +
       	Topic     string

     

       7
       +
       	IndexedAt string

     

       8
       +
       }

     

       9
       +
       

     

       10
       +
       type MessageFrameHeaderCBOR struct {

     

       11
       +
       	Op   int64  `cbor:"op"`

     

       12
       +
       	Kind string `cbor:"t"`

     

       13
       +
       }

     

       14
       +
       

     

       15
       +
       type MessageFrameCommitCBOR struct {

     

       16
       +
       	Did string `cbor:"repo"`

     

       17
       +
       	Ops []struct {

     

       18
       +
       		Action string `cbor:"action"`

     

       19
       +
       		Path   string `cbor:"path"`

     

       20
       +
       		RawCID []byte `cbor:"cid"`

     

       21
       +
       	} `cbor:"ops"`

     

       22
       +
       	Blocks []byte `cbor:"blocks"`

     

       23
       +
       	Blobs  []byte `cbor:"blobs"`

     

       24
       +
       }

     

       25
       +
       

     

       26
       +
       type MessageFrameCBOR struct {

     

       27
       +
       	Header MessageFrameHeaderCBOR

     

       28
       +
       	Commit MessageFrameCommitCBOR

     

       29
       +
       }

     

       30
       +
       

     

       31
       +
       type BlockCBOR struct {

     

       32
       +
       	Text  string `cbor:"text"`

     

       33
       +
       	Embed struct {

     

       34
       +
       		Kind   string `cbor:"$type"`

     

       35
       +
       		Images []struct {

     

       36
       +
       			Alt   string `cbor:"alt"`

     

       37
       +
       			Image struct {

     

       38
       +
       				Kind string `cbor:"$type"`

     

       39
       +
       				Ref  []byte `cbor:"ref"`

     

       40
       +
       				// Ref  struct {

     

       41
       +
       				// 	LinkRawCid []byte `cbor:"$link"`

     

       42
       +
       				// } `cbor:"ref"`

     

       43
       +
       				MimeType string `cbor:"mimeType"`

     

       44
       +
       				Size     int    `cbor:"size"`

     

       45
       +
       			} `cbor:"image"`

     

       46
       +
       			AspectRatio struct {

     

       47
       +
       				Width  int

     

       48
       +
       				Height int

     

       49
       +
       			} `cbor:"aspectRatio"`

     

       50
       +
       		} `cbor:"images,omitempty"`

     

       51
       +
       	} `cbor:"embed,omitempty"`

     

       52
       +
       }

     

       53
       +
       

     

       54
       +
       type ComBskyFeedPost struct {

     

       55
       +
       	Did    string

     

       56
       +
       	Kind   string

     

       57
       +
       	Commit struct {

     

       58
       +
       		Rev        string

     

       59
       +
       		Operation  string

     

       60
       +
       		Collection string

     

       61
       +
       		Cid        string

     

       62
       +
       		Record     struct {

     

       63
       +
       			Type  string `json:"$type"`

     

       64
       +
       			Text  string

     

       65
       +
       			Reply struct {

     

       66
       +
       				Parent struct {

     

       67
       +
       					Cid string

     

       68
       +
       					Uri string

     

       69
       +
       				} `json:"parent,omitempty"`

     

       70
       +
       				Root struct {

     

       71
       +
       					Cid string

     

       72
       +
       					Uri string

     

       73
       +
       				} `json:"root,omitempty"`

     

       74
       +
       			} `json:"reply,omitempty"`

     

       75
       +
       		}

     

       76
       +
       	}

     

       77
       +
       }

+17

src/utils.go

···

       1
       +
       package main

     

       2
       +
       

     

       3
       +
       import (

     

       4
       +
       	"os"

     

       5
       +
       	"strings"

     

       6
       +
       )

     

       7
       +
       

     

       8
       +
       func GetEnvironmentVariables() map[string]string {

     

       9
       +
       	env := map[string]string{}

     

       10
       +
       

     

       11
       +
       	for _, pair := range os.Environ() {

     

       12
       +
       		parts := strings.SplitN(pair, "=", 2)

     

       13
       +
       		env[parts[0]] = parts[1]

     

       14
       +
       	}

     

       15
       +
       

     

       16
       +
       	return env

     

       17
       +
       }