Support syncing event cancel

apiserver/model_booking.go

@@ -32,6 +32,9 @@ type Booking struct {
 
 	// The name of the organizer.
 	OrganizerName string `json:"organizerName,omitempty"`
+
+	// Indicates that the event was cancelled.
+	Cancelled bool `json:"cancelled,omitempty"`
 }
 
 // AssertBookingRequired checks if the required fields are not zero-ed

apiserver/model_bookings_listen.go

@@ -33,6 +33,9 @@ type BookingsListen struct {
 	// The name of the organizer.
 	OrganizerName string `json:"organizerName,omitempty"`
 
+	// Indicates that the event was cancelled.
+	Cancelled bool `json:"cancelled,omitempty"`
+
 	// The status code expecting when actually perform the operation. Some values are - 200: updated (ok)  - 201: created - 204: deleted (no content) - 304: unchanged (not modified) - 400: problem (bad request) - 404: not found - 409: duplicated (conflict) - 422: unprocessable
 	StatusCode int32 `json:"statusCode,omitempty"`
 }

apiservices/api_booking_service.go

@@ -38,11 +38,19 @@ func NewBookingAPIService() apiserver.BookingAPIServicer {
 
 // BookingsBookingIdDelete - Cancel a booking
 func (s *BookingAPIService) BookingsBookingIdDelete(ctx context.Context, bookingId int32) (apiserver.ImplResponse, error) {
-	if err := conf.CancelEvent(ctx, int64(bookingId)); errors.Is(err, conf.ErrNotFound) {
+	booking, err := conf.CancelEvent(ctx, int64(bookingId))
+	if errors.Is(err, conf.ErrNotFound) {
 		return apiserver.ImplResponse{Code: http.StatusNotFound}, err
 	} else if err != nil {
 		return apiserver.ImplResponse{Code: http.StatusInternalServerError}, err
 	}
+
+	for _, assetID := range booking.AssetIds {
+		for _, subscriber := range assetSubscriptions[assetID] {
+			subscriber.conn.WriteJSON(booking)
+		}
+	}
+
 	return apiserver.Response(http.StatusOK, nil), nil
 }
 

conf/conf.go

@@ -200,6 +200,7 @@ func dbEventToAPIBooking(ctx context.Context, e appdb.Event) (apiserver.Booking,
 		Start:       e.StartTime,
 		End:         e.EndTime,
 		OrganizerID: e.Organizer,
+		Cancelled:   e.CancelledAt.Valid,
 	}, nil
 }
 
@@ -220,24 +221,27 @@ func dbEventToAPIBooking(ctx context.Context, e appdb.Event) (apiserver.Booking,
 // 	return events, nil
 // }
 
-func CancelEvent(ctx context.Context, eventID int64) error {
+func CancelEvent(ctx context.Context, eventID int64) (apiserver.Booking, error) {
 	event, err := appdb.Events(
 		appdb.EventWhere.ID.EQ(eventID),
 	).OneG(ctx)
 	if errors.Is(err, sql.ErrNoRows) {
-		return ErrNotFound
+		return apiserver.Booking{}, ErrNotFound
 	}
 	if err != nil {
-		return fmt.Errorf("fetching event to cancel: %v", err)
+		return apiserver.Booking{}, fmt.Errorf("fetching event to cancel: %v", err)
 	}
 
 	event.CancelledAt = null.TimeFrom(time.Now())
 
 	if _, err := event.UpdateG(ctx, boil.Whitelist(appdb.EventColumns.CancelledAt)); err != nil {
-		return fmt.Errorf("updating event to mark as cancelled: %v", err)
+		return apiserver.Booking{}, fmt.Errorf("updating event to mark as cancelled: %v", err)
 	}
-
-	return nil
+	apiBooking, err := dbEventToAPIBooking(ctx, *event)
+	if err != nil {
+		return apiserver.Booking{}, fmt.Errorf("converting db event to api booking: %v", err)
+	}
+	return apiBooking, nil
 }
 
 // func GetCurrentEvents(ctx context.Context) ([]apiserver.Booking, error) {

openapi.yaml

@@ -288,6 +288,9 @@ components:
         organizerName:
           type: string
           description: The name of the organizer.
+        cancelled:
+          type: boolean
+          description: Indicates that the event was cancelled.
     BookingRequest:
       type: object
       properties: