Compare commits

..

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

1 changed files with 21 additions and 38 deletions

View File

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