diff options
| author | Baitinq <manuelpalenzuelamerino@gmail.com> | 2024-05-27 21:30:54 +0200 |
|---|---|---|
| committer | Baitinq <manuelpalenzuelamerino@gmail.com> | 2024-05-27 23:52:44 +0200 |
| commit | 81621c4f64f4a1c29906643f53314e2f71a014ae (patch) | |
| tree | 503cc56b609dcad8f8eca6e64b6b9b15b02fd4fd /src/payload-processor/processor/processor.go | |
| parent | payload-processor: fmt (diff) | |
| download | fs-tracer-backend-81621c4f64f4a1c29906643f53314e2f71a014ae.tar.gz fs-tracer-backend-81621c4f64f4a1c29906643f53314e2f71a014ae.tar.bz2 fs-tracer-backend-81621c4f64f4a1c29906643f53314e2f71a014ae.zip | |
rest-api: connect to db and add /file/ GET endpoint
TODO: Only get files for your specific user
Diffstat (limited to 'src/payload-processor/processor/processor.go')
| -rw-r--r-- | src/payload-processor/processor/processor.go | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/payload-processor/processor/processor.go b/src/payload-processor/processor/processor.go index 889f4c0..ab128cb 100644 --- a/src/payload-processor/processor/processor.go +++ b/src/payload-processor/processor/processor.go @@ -11,6 +11,7 @@ import ( "syscall" "time" + "github.com/Baitinq/fs-tracer-backend/lib" "github.com/google/uuid" "github.com/jmoiron/sqlx" "github.com/segmentio/kafka-go" @@ -92,7 +93,7 @@ func (p Processor) process(ctx context.Context, cancel context.CancelFunc) { func (p Processor) handleMessage(ctx context.Context, m kafka.Message) error { fmt.Printf("(%s): message at paritition %d: offset %d: %s = %s\n", time.Now().String(), m.Partition, m.Offset, string(m.Key), string(m.Value)) - var file File + var file lib.File err := json.Unmarshal(m.Value, &file) if err != nil { return err |