Sample protos build

.gitignore

@@ -21,3 +21,4 @@ debug
 *.db
 *.conf
 *.lock
+.proto_checksums

Makefile

@@ -73,3 +73,48 @@ xdr-clean:
 	rm $(DOWNLOADABLE_XDRS) || true
 
 xdr-update: xdr-clean xdr
+
+
+##############
+PROTO_DIR := protos
+GEN_SUFFIX := .pb.go
+PROTO_FILES := $(shell find $(PROTO_DIR) -name "*.proto")
+PROTO_CHECKSUM := .proto_checksums
+
+generate-proto:
+	@echo "Regenerating proto files..."
+	@touch $(PROTO_CHECKSUM)
+	@current_checksum=$$(sha256sum $(PROTO_FILES) | sha256sum | awk '{print $$1}'); \
+	stored_checksum=$$(cat $(PROTO_CHECKSUM)); \
+	if [ "$${current_checksum}" != "$${stored_checksum}" ]; then \
+    	echo "Changes detected. Regenerating all proto files..."; \
+    	MAP_OPTS=$$(for file in $(PROTO_FILES); do \
+    		rel_path=$$(echo $$file | sed 's|$(PROTO_DIR)/||'); \
+    		pkg_path=$$(dirname $$rel_path); \
+    		go_pkg="github.com/stellar/go/ingest/$$pkg_path"; \
+    		printf "M%s=%s," "$$rel_path" "$$go_pkg"; \
+    	done); \
+    	MAP_OPTS=$${MAP_OPTS%,}; \
+    	echo "Running protoc with options:"; \
+    	echo "  --go_out=ingest"; \
+    	echo "  --go_opt=paths=source_relative"; \
+    	echo "  --go_opt=$$MAP_OPTS"; \
+    	echo "Proto Files:  $(PROTO_FILES)"; \
+    	protoc -I=$(PROTO_DIR) \
+    	       --go_out=ingest --go_opt=paths=source_relative \
+    	       --go_opt=$$MAP_OPTS \
+    	       $(PROTO_FILES); \
+    	echo "$${current_checksum}" > $(PROTO_CHECKSUM); \
+    else \
+    	echo "No changes detected in proto files."; \
+    fi
+
+
+regenerate-proto: $(PROTO_CHECKSUM)
+	rm -f $(PROTO_CHECKSUM)
+	$(MAKE) generate-proto
+
+$(PROTO_CHECKSUM):
+	@touch $(PROTO_CHECKSUM)
+
+.PHONY: generate-proto regenerate-proto

go.mod

@@ -62,6 +62,7 @@ require (
 	github.com/docker/docker v27.3.1+incompatible
 	github.com/docker/go-connections v0.5.0
 	github.com/fsouza/fake-gcs-server v1.49.2
+	google.golang.org/protobuf v1.34.2
 )
 
 require (
@@ -85,6 +86,7 @@ require (
 	github.com/go-logr/stdr v1.2.2 // indirect
 	github.com/gobuffalo/packd v1.0.2 // indirect
 	github.com/gogo/protobuf v1.3.2 // indirect
+	github.com/golang/protobuf v1.5.4 // indirect
 	github.com/google/pprof v0.0.0-20210720184732-4bb14d4b1be1 // indirect
 	github.com/google/renameio/v2 v2.0.0 // indirect
 	github.com/google/s2a-go v0.1.7 // indirect
@@ -134,7 +136,6 @@ require (
 	github.com/fatih/structs v1.0.0 // indirect
 	github.com/gavv/monotime v0.0.0-20161010190848-47d58efa6955 // indirect
 	github.com/golang/groupcache v0.0.0-20210331224755-41bb18bfe9da // indirect
-	github.com/golang/protobuf v1.5.4 // indirect
 	github.com/google/go-cmp v0.6.0 // indirect
 	github.com/google/go-querystring v0.0.0-20160401233042-9235644dd9e5 // indirect
 	github.com/googleapis/gax-go/v2 v2.12.4 // indirect
@@ -178,7 +179,6 @@ require (
 	google.golang.org/appengine v1.6.8 // indirect
 	google.golang.org/genproto v0.0.0-20240528184218-531527333157 // indirect
 	google.golang.org/grpc v1.64.1 // indirect
-	google.golang.org/protobuf v1.34.2 // indirect
 	gopkg.in/tomb.v1 v1.0.0-20141024135613-dd632973f1e7 // indirect
 	gopkg.in/yaml.v3 v3.0.1 // indirect
 )

ingest/address/address_helpers.go

@@ -0,0 +1,20 @@
+package address
+
+import (
+	"fmt"
+)
+
+func (a *Address) BetterString() string {
+	switch addr := a.AddressType.(type) {
+	case *Address_SmartContractAddress:
+		return fmt.Sprintf("Smart Contract Address: %s", addr.SmartContractAddress)
+	case *Address_AccountAddress:
+		return fmt.Sprintf("Account Address: %s", addr.AccountAddress)
+	case *Address_LiquidityPoolHash:
+		return fmt.Sprintf("Liquidity Pool Hash: %s", addr.LiquidityPoolHash)
+	case *Address_ClaimableBalanceId:
+		return fmt.Sprintf("Claimable Balance ID: %s", addr.ClaimableBalanceId)
+	default:
+		return "Unknown Address Type"
+	}
+}