Modify completed analysis topic environment variable and add documentation for running locally (#531)

* fix merge conflict

* Publish notification after analysis for a new package is completed

* Modify worker to use package representation from resultstore for completed analysis notifications

* Fix style to address review comments

* Make notificationTopic consistent with other variables
* Make error messages more concise
* Modify publishNotification parameters to take in raw input
* Remove unecessary variables

* Fix topic name for consistency

Signed-off-by: Ada Luong <[email protected]>

* Create notification package

Signed-off-by: Ada Luong <[email protected]>

* Make completed analysis notifications optional

Signed-off-by: Ada Luong <[email protected]>

* Fix naming for notification message variables

Signed-off-by: Ada Luong <[email protected]>

* Simplify notification sending logic by moving it into messageLoop

Signed-off-by: Ada Luong <[email protected]>

* clarified comment about the notificationTopic default value

Signed-off-by: Ada Luong <[email protected]>

* Add command to observe notifications topic

Signed-off-by: Ada Luong <[email protected]>

* Update config file to set environment variable for complete analysis notification

Signed-off-by: Ada Luong <[email protected]>

Signed-off-by: Ada Luong <[email protected]>
Co-authored-by: Ada Luong <[email protected]>
Co-authored-by: Oliver Chang <[email protected]>

Author: 3 people

examples/e2e/README.md

@@ -39,6 +39,7 @@ Output from the Kafka PubSub topics can be inspected using
 2. Run `kafkacat` to observe the topics:
     - package-feeds: `kafkacat -C -J -b localhost:9094 -t package-feeds`
     - workers: `kafkacat -C -J -b localhost:9094 -t workers`
+    - notifications: `kafkacat -C -J -b localhost:9094 -t notifications`
 
 ## Additional Notes
 

infra/worker/workers-set.yaml

@@ -32,7 +32,7 @@ spec:
         - name: OSSF_MALWARE_ANALYSIS_PACKAGES
           value: gs://ossf-malware-analysis-packages
         - name: OSSF_MALWARE_NOTIFICATION_TOPIC
-          value: gcppubsub://projects/gosst-package-detection/subscriptions/analysis-notify
+          value: gcppubsub://projects/ossf-malware-analysis/topics/analysis-notify
         securityContext:
           privileged: true
         volumeMounts: