/
operations_mensaje.go
125 lines (106 loc) · 3.23 KB
/
operations_mensaje.go
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
package operations
import (
"../helper"
"../models"
"encoding/json"
"github.com/gorilla/mux"
"log"
"net/http"
"go.mongodb.org/mongo-driver/bson"
"go.mongodb.org/mongo-driver/bson/primitive"
"go.mongodb.org/mongo-driver/mongo"
"context"
"fmt"
)
func getClient2() *mongo.Collection {
return helper.ConnectDB("condma", "mensajes")
}
func CreaMensaje(w http.ResponseWriter, r *http.Request){
w.Header().Set("Content-Type", "application/json")
defer r.Body.Close()
var msg models.TableroMsg
err := json.NewDecoder(r.Body).Decode(&msg)
if err != nil {
ResponseWriter(w, http.StatusBadRequest, "body json request have issues!!!", nil)
return
}
msg.ID = primitive.NewObjectID()
result, err := getClient2().InsertOne(nil, msg)
if err != nil {
switch err.(type) {
case mongo.WriteException:
ResponseWriter(w, http.StatusNotAcceptable, "Mensaje already exists in database.", nil)
default:
ResponseWriter(w, http.StatusInternalServerError, "Error while inserting data.", nil)
}
return
}
msg.ID = result.InsertedID.(primitive.ObjectID)
ResponseWriter(w, http.StatusCreated, "", msg)
}
func GetMensaje(w http.ResponseWriter, r *http.Request){
w.Header().Set("Content-Type", "application/json")
client := getClient2()
id, _ := primitive.ObjectIDFromHex(string(mux.Vars(r)["id"]))
filter := bson.M{"_id": id}
var msg models.TableroMsg
err := client.FindOne(context.TODO(), filter).Decode(&msg)
if err != nil {
fmt.Println(err)
ResponseWriter(w, http.StatusInternalServerError, "error in updating document!!!", nil)
}
ResponseWriter(w, http.StatusOK, "", msg)
}
func GetMensajes(w http.ResponseWriter, r *http.Request) {
w.Header().Set("Content-Type", "application/json")
client := getClient2()
cursor, err := client.Find(context.TODO(), bson.M{})
if err != nil {
log.Fatal("pendejo " +
"", err)
//panic(err)
ResponseWriter(w, http.StatusInternalServerError, "error in updating document!!!", nil)
}
defer cursor.Close(context.TODO())
var msgs []*models.TableroMsg
for cursor.Next(context.TODO()){
var msg models.TableroMsg
if err = cursor.Decode(&msg); err != nil{
log.Fatal("la muerte")
ResponseWriter(w, http.StatusInternalServerError, "error in updating document!!!", nil)
return
}
msgs = append(msgs, &msg)
}
//ResponseWriter(w, http.StatusOK, "", &msgs)
if len(msgs) != 0 {
ResponseWriter(w, http.StatusOK, "", &msgs)
} else {
ResponseWriter(w, http.StatusNotFound, "Sin mensajes", nil)
}
}
func ActualizaMensajes(w http.ResponseWriter, r *http.Request){
w.Header().Set("Content-Type", "application/json")
id, _ := primitive.ObjectIDFromHex(string(mux.Vars(r)["id"]))
client := getClient2()
var updateData map[string]interface{}
err := json.NewDecoder(r.Body).Decode(&updateData)
update := bson.M{
"$set":
bson.M{
"habilitado": 0,
//"nombre": "dsadas",
},
}
result, err := client.UpdateOne(context.Background(), bson.M{"_id": id}, update)
if err != nil {
log.Printf("Error while updateing document: %v", err)
ResponseWriter(w, http.StatusInternalServerError, "error in updating document!!!", nil)
return
}
if result.MatchedCount == 1 {
ResponseWriter(w, http.StatusOK, "", &updateData)
} else {
ResponseWriter(w, http.StatusNotFound, "Message not found", nil)
}
}