Compare commits

..

No commits in common. "28c8fa8a90fa461661490bc135f5524542527b9a" and "696cd1d87f5a716baf60c20c326b3b46731f4da5" have entirely different histories.

1 changed files with 21 additions and 38 deletions

View File

@ -331,38 +331,30 @@ func contains(s []*agenda.Subscription, e string) bool {
} }
// /////////////////////////Delete subscriber/////////////////////////////// // /////////////////////////Delete subscriber///////////////////////////////
func (h *ApplicationHandler) AgendaDeleteSubscribeEvent(w http.ResponseWriter, r *http.Request) { func (h *ApplicationHandler) AgendaDeleteSubscribeEvent(w http.ResponseWriter, r *http.Request) {
vars := mux.Vars(r) vars := mux.Vars(r)
eventId := vars["eventid"] eventId := vars["eventid"]
subscribeid := vars["subscribeid"] subscribeid := vars["subscribeid"]
s_b_id := ""
s_b_name := ""
s_b_group_id := ""
s_b_group_name := ""
request := &agenda.GetEventRequest{
Id: eventId,
}
resp, err := h.services.GRPC.Agenda.GetEvent(context.TODO(), request) /////////////////////////Test ajout motif///////////////////////////////
if err != nil { // dd, _ := structpb.NewStruct(map[string]any{})
fmt.Println(err) // request := &agenda.GetEventRequest{
w.WriteHeader(http.StatusInternalServerError) // Id: eventId,
return // }
}
for i := range resp.Event.Subscriptions { // resp, err := h.services.GRPC.Agenda.GetEvent(context.TODO(), request)
if resp.Event.Subscriptions[i].Subscriber == subscribeid { // if err != nil {
subscribed_by_id := resp.Event.Subscriptions[i].Data.Fields["subscribed_by"].GetStructValue().Fields["user"].GetStructValue().Fields["id"].GetStringValue() // fmt.Println(err)
subscribed_by_name := resp.Event.Subscriptions[i].Data.Fields["subscribed_by"].GetStructValue().Fields["user"].GetStructValue().Fields["display_name"].GetStringValue() // w.WriteHeader(http.StatusInternalServerError)
subscribed_by_group_id := resp.Event.Subscriptions[i].Data.Fields["subscribed_by"].GetStructValue().Fields["group"].GetStructValue().Fields["id"].GetStringValue() // return
subscribed_by_group_name := resp.Event.Subscriptions[i].Data.Fields["subscribed_by"].GetStructValue().Fields["group"].GetStructValue().Fields["name"].GetStringValue() // }
s_b_id = subscribed_by_id
s_b_name = subscribed_by_name // for i := range resp.Event.Subscriptions {
s_b_group_id = subscribed_by_group_id // if resp.Event.Subscriptions[i].Subscriber == subscribeid {
s_b_group_name = subscribed_by_group_name // d := resp.Event.Subscriptions[i].Data
} // dd = d
} // }
// }
current_group, err := h.currentGroup(r) current_group, err := h.currentGroup(r)
if err != nil { if err != nil {
@ -379,16 +371,6 @@ func (h *ApplicationHandler) AgendaDeleteSubscribeEvent(w http.ResponseWriter, r
} }
data := map[string]any{ data := map[string]any{
"subscribed_by": map[string]any{
"user": map[string]any{
"id": s_b_id,
"display_name": s_b_name,
},
"group": map[string]any{
"id": s_b_group_id,
"name": s_b_group_name,
},
},
"unsubscribed_by": map[string]any{ "unsubscribed_by": map[string]any{
"user": map[string]any{ "user": map[string]any{
"id": current_user_token.Subject, "id": current_user_token.Subject,
@ -401,7 +383,6 @@ func (h *ApplicationHandler) AgendaDeleteSubscribeEvent(w http.ResponseWriter, r
}, },
"motif": r.FormValue("motif"), "motif": r.FormValue("motif"),
} }
datapb, err := structpb.NewStruct(data) datapb, err := structpb.NewStruct(data)
if err != nil { if err != nil {
fmt.Println(err) fmt.Println(err)
@ -416,6 +397,8 @@ func (h *ApplicationHandler) AgendaDeleteSubscribeEvent(w http.ResponseWriter, r
Data: datapb, Data: datapb,
} }
_, err := h.services.GRPC.Agenda.DeleteSubscription(context.TODO(), request) _, err := h.services.GRPC.Agenda.DeleteSubscription(context.TODO(), request)
if err != nil { if err != nil {