Flush (#32)

* Add flush on icc

* Change default Port to 9007

README.md

@@ -74,7 +74,7 @@ printed immediately.
 To listen to messages, you can use this command:
 
 ```
-curl -N localhot:9013/system/icc/notify?meeting_id=5
+curl -N localhot:9007/system/icc/notify?meeting_id=5
 ```
 
 The meeting_id query argument is optional.
@@ -97,7 +97,7 @@ Each other other line is one notify message. It has the following format:
 To publish a message, you can use the following request:
 
 ```
-curl localhost:9013/system/icc/notify/publish -d '{
+curl localhost:9007/system/icc/notify/publish -d '{
   "channel_id": "STRING_SEE_ABOVE",
   "to_meeting": 5,
   "to_users": [3,4],
@@ -124,7 +124,7 @@ from the autoupdate-service repo.
 To listen to messages, you can use this command:
 
 ```
-curl -N localhot:9013/system/icc/notify?meeting_id=5
+curl -N localhot:9007/system/icc/notify?meeting_id=5
 ```
 
 The meeting_id argument is required.
@@ -138,7 +138,7 @@ The returned messages have the format:
 To send applause, use:
 
 ```
-curl localhost:9013/system/icc/applause/send?meeting_id=1
+curl localhost:9007/system/icc/applause/send?meeting_id=1
 ```
 
 The argument meeting_id is required.
@@ -154,8 +154,8 @@ TODO
 
 The Service uses the following environment variables:
 
-* `ICC_PORT`: Lets the service listen on port 9013. The default is
-  `9013`.
+* `ICC_PORT`: Lets the service listen on port 9007. The default is
+  `9007`.
 * `ICC_HOST`: The device where the service starts. The default is am
   empty string which starts the service on any device.
 * `ICC_REDIS_HOST`: The host of the redis instance to save icc messages. The

internal/notify/http.go

@@ -49,6 +49,7 @@ func HandleReceive(mux *http.ServeMux, notify Receiver, auth icchttp.Authenticat
 			icchttp.Error(w, fmt.Errorf("sending channel id: %w", err))
 			return
 		}
+		w.(http.Flusher).Flush()
 
 		encoder := json.NewEncoder(w)
 
@@ -63,6 +64,8 @@ func HandleReceive(mux *http.ServeMux, notify Receiver, auth icchttp.Authenticat
 				icchttp.ErrorNoStatus(w, fmt.Errorf("sending message: %w", err))
 				return
 			}
+
+			w.(http.Flusher).Flush()
 		}
 	})
 

internal/run/run.go

@@ -91,7 +91,7 @@ func Run(ctx context.Context, environment []string, secret func(name string) (st
 // defaut values.
 func defaultEnv(environment []string) map[string]string {
 	env := map[string]string{
-		"ICC_PORT": "9013",
+		"ICC_PORT": "9007",
 
 		"ICC_REDIS_HOST": "localhost",
 		"ICC_REDIS_PORT": "6379",