mirror of https://github.com/farcasterxyz/hub-monorepo.git synced 2026-01-09 13:18:04 -05:00

Go to file

Aditi Srinivasan 41b1f35466 fix: only maintain counts for expected events in event stream monitoring (#2612 )

## Why is this change needed?

We're producing a lot of errors with 0 missing events due to this bug. 

## Merge Checklist

_Choose all relevant options below by adding an `x` now or at any time
before submitting for review_

- [x] PR title adheres to the [conventional
commits](https://www.conventionalcommits.org/en/v1.0.0/) standard
- [x] PR has a
[changeset](https://github.com/farcasterxyz/hub-monorepo/blob/main/CONTRIBUTING.md#35-adding-changesets)
- [x] PR has been tagged with a change label(s) (i.e. documentation,
feature, bugfix, or chore)
- [ ] PR includes
[documentation](https://github.com/farcasterxyz/hub-monorepo/blob/main/CONTRIBUTING.md#32-writing-docs)
if necessary.


<!-- start pr-codex -->

---

## PR-Codex overview
This PR focuses on improving event stream monitoring by ensuring that
only counts for expected events are maintained, thereby optimizing the
handling of event data.

### Detailed summary
- Modified the `setBlockCounts` method in the `eventStream.ts` file.
- Changed the way event counts are retrieved: now checks if the count is
`undefined` before setting it in Redis.
- Removed the default count of `0`, ensuring only relevant counts are
stored.

> ✨ Ask PR-Codex anything about this PR by commenting with `/codex {your
question}`

<!-- end pr-codex -->

2025-06-25 18:59:26 -04:00

.changeset

fix: only maintain counts for expected events in event stream monitoring (#2612 )

2025-06-25 18:59:26 -04:00

.github

chore: Refactor test targets (#2583 )

2025-05-16 22:25:37 -07:00

.husky

chore: upgrade husky to v9 (#2158 )

2024-07-11 10:01:03 -07:00

.vscode

fix: fix sync id retrieval for sync health job (#2240 )

2024-08-07 15:49:06 -04:00

packages

fix: only maintain counts for expected events in event stream monitoring (#2612 )

2025-06-25 18:59:26 -04:00

.dockerignore

chore: Support pure ESM output (#994 )

2023-05-24 20:02:38 -07:00

.editorconfig

feat(sync): Merkle trie to keep track messages merged by the engine (#145 )

2022-10-07 16:49:11 -07:00

.gitignore

submit missing messages via the sync health job and output richer logs (#2238 )

2024-08-06 18:42:02 -04:00

.yarnrc

fix: debug deploy failures by switching to npm registry (#185 )

2022-10-28 16:23:14 -07:00

biome.json

chore: replace rome with biome (#1351 )

2023-09-07 08:43:02 -05:00

codecov.yml

chore(hubble): use viem to interact with ethereum (#997 )

2023-06-22 14:50:18 -05:00

CONTRIBUTING.md

chore: Remove references to Hubble (#2581 )

2025-05-16 21:41:45 -07:00

generate-protos.sh

feat: set up monitoring for event stream based on snapchain block numbers (#2607 )

2025-06-25 13:20:24 -04:00

LICENSE

Update LICENSE (#2492 )

2025-01-27 13:52:57 -08:00

package.json

chore: Remove references to Hubble (#2581 )

2025-05-16 21:41:45 -07:00

README.md

chore: Remove more references to Hubble (#2582 )

2025-05-16 22:12:31 -07:00

tsconfig.json

chore: upgrade libp2p all the way (#2224 )

2024-07-30 18:04:48 -05:00

turbo.json

Revert "chore: upgrade turborepo to v2" (#2170 )

2024-07-12 11:53:53 -07:00

yarn.lock

chore: Remove references to Hubble (#2581 )

2025-05-16 21:41:45 -07:00

README.md

Hub Monorepo

This monorepo contains packages used to communicate with a Farcaster Hub.

Getting Started

See CONTRIBUTING.md to set up your developer environment and learn about how to contribute.

Code Organization

The repository is a monorepo with a primary application in the /apps/ folder that imports several packages /packages/. It is written primarily in Typescript and uses Yarn to orchestrate tasks and TurboRepo as its build system. Some performance intensive code is written in Rust and compiled with Cargo.

Packages

Package Name	Description
@farcaster/shuttle	A package that streams Hubble events to Postgres
@farcaster/hub-nodejs	A Node.js client library for Hubble
@farcaster/hub-web	A Browser client library for Hubble
@farcaster/core	Shared code between all packages