Fix/fastsync

.gitignore

@@ -46,4 +46,25 @@ __debug_bin
 vendor/
 
 # Internal team references
-docs/SONARQUBE_SETUP_GUIDE.md
+docs/SONARQUBE_SETUP_GUIDE.md
+ADR-001-JMDT-Native-EVM-Smart-Contracts.docx
+jmdn.yaml
+contract_storage_pebble/000004.log
+*.log
+*.logs
+*.db
+*.db-wal
+contract_storage_pebble/CURRENT
+contract_storage_pebble/LOCK
+contract_storage_pebble/MANIFEST-000001
+contract_storage_pebble/MANIFEST-000005
+contract_storage_pebble/*
+SmartContract/artifacts/*
+SmartContract/artifacts/HelloWorld.json
+/SmartContract/artifacts
+SmartContract/artifacts/HelloWorld.json
+docs/refactor-contractDBOps.md
+internal/WAL/.tmp/*
+.claude/*
+.code-review-graph/*
+.cursor/*

AVC/BuddyNodes/MessagePassing/ListenerHandler.go

@@ -1110,6 +1110,13 @@ func (lh *ListenerHandler) handleSubmitVote(logger_ctx context.Context, s networ
 			ion.String("topic", TOPIC),
 			ion.String("function", "MessagePassing.handleSubmitVote"))
 
+		// Notify the sequencer's vote collector (if this node IS the sequencer)
+		NotifyVoteCollector(AVCStruct.VoteNotification{
+			PeerID:    remotePeer.String(),
+			BlockHash: blockHash,
+			Vote:      int8(voteValue),
+		})
+
 		// Now publish the vote to pubsub so ALL other buddy nodes can receive it
 		if pubSubNode != nil && pubSubNode.PubSub != nil {
 			logger().NamedLogger.Info(voteSpanCtx, "Republishing vote to pubsub for all buddy nodes",
@@ -1904,7 +1911,11 @@ func (lh *ListenerHandler) TriggerForBFTFromSequencer(s network.Stream, message
 					if err := json.Unmarshal([]byte(msg.Message), &resultData); err == nil {
 						if result, ok := resultData["result"].(float64); ok {
 							voteResult := int8(result)
-							Maps.StoreVoteResult(buddyID.String(), voteResult)
+							resultBlockHash := ""
+							if bh, ok := resultData["block_hash"].(string); ok {
+								resultBlockHash = bh
+							}
+							Maps.StoreVoteResult(resultBlockHash, buddyID.String(), voteResult)
 							fmt.Printf("✅ Stored vote result for peer %s: %d\n", buddyID.String(), voteResult)
 							responsesMutex.Lock()
 							responsesReceived++

AVC/BuddyNodes/MessagePassing/vote_collector.go

@@ -0,0 +1,53 @@
+package MessagePassing
+
+import (
+	"log"
+	"sync"
+
+	PubSubMessages "gossipnode/config/PubSubMessages"
+)
+
+// activeVoteCollector is the channel the sequencer registers to receive
+// vote notifications pushed from handleSubmitVote. Only one consensus
+// round is active per node at a time, so a single global channel is safe.
+var (
+	activeVoteCollector chan<- PubSubMessages.VoteNotification
+	voteCollectorMu     sync.RWMutex
+)
+
+// RegisterVoteCollector sets the active vote notification channel.
+// The sequencer calls this at the start of its event-driven vote collection loop.
+func RegisterVoteCollector(ch chan<- PubSubMessages.VoteNotification) {
+	voteCollectorMu.Lock()
+	activeVoteCollector = ch
+	voteCollectorMu.Unlock()
+}
+
+// UnregisterVoteCollector nils out the active collector.
+// Called via defer when the consensus round completes or times out.
+func UnregisterVoteCollector() {
+	voteCollectorMu.Lock()
+	activeVoteCollector = nil
+	voteCollectorMu.Unlock()
+}
+
+// NotifyVoteCollector sends a vote notification to the active collector
+// (if one is registered). The send is non-blocking; if the channel is full
+// or no collector is registered, the notification is dropped with a log warning.
+func NotifyVoteCollector(notification PubSubMessages.VoteNotification) {
+	voteCollectorMu.RLock()
+	collector := activeVoteCollector
+	voteCollectorMu.RUnlock()
+
+	if collector == nil {
+		return
+	}
+
+	select {
+	case collector <- notification:
+		log.Printf("VoteCollector: notified sequencer of vote from %s for block %s (vote=%d)",
+			notification.PeerID, notification.BlockHash, notification.Vote)
+	default:
+		log.Printf("VoteCollector: channel full, dropping vote notification from %s", notification.PeerID)
+	}
+}

CLAUDE.md

@@ -179,3 +179,42 @@ Proto definitions live in `proto/`. The gRPC services are:
 ## Linter Notes
 
 Active linters: `govet`, `ineffassign`, `unused`, `nolintlint`. `staticcheck`, `errcheck`, and `gosec` are disabled pending backlog cleanup — do not re-enable them in a PR without addressing existing violations first.
+
+<!-- code-review-graph MCP tools -->
+## MCP Tools: code-review-graph
+
+**IMPORTANT: This project has a knowledge graph. ALWAYS use the
+code-review-graph MCP tools BEFORE using Grep/Glob/Read to explore
+the codebase.** The graph is faster, cheaper (fewer tokens), and gives
+you structural context (callers, dependents, test coverage) that file
+scanning cannot.
+
+### When to use graph tools FIRST
+
+- **Exploring code**: `semantic_search_nodes` or `query_graph` instead of Grep
+- **Understanding impact**: `get_impact_radius` instead of manually tracing imports
+- **Code review**: `detect_changes` + `get_review_context` instead of reading entire files
+- **Finding relationships**: `query_graph` with callers_of/callees_of/imports_of/tests_for
+- **Architecture questions**: `get_architecture_overview` + `list_communities`
+
+Fall back to Grep/Glob/Read **only** when the graph doesn't cover what you need.
+
+### Key Tools
+
+| Tool | Use when |
+|------|----------|
+| `detect_changes` | Reviewing code changes — gives risk-scored analysis |
+| `get_review_context` | Need source snippets for review — token-efficient |
+| `get_impact_radius` | Understanding blast radius of a change |
+| `get_affected_flows` | Finding which execution paths are impacted |
+| `query_graph` | Tracing callers, callees, imports, tests, dependencies |
+| `semantic_search_nodes` | Finding functions/classes by name or keyword |
+| `get_architecture_overview` | Understanding high-level codebase structure |
+| `refactor_tool` | Planning renames, finding dead code |
+
+### Workflow
+
+1. The graph auto-updates on file changes (via hooks).
+2. Use `detect_changes` for code review.
+3. Use `get_affected_flows` to understand impact.
+4. Use `query_graph` pattern="tests_for" to check coverage.