MCPcopy Index your code
hub / github.com/deepflowio/deepflow / createPlugin

Function createPlugin

server/controller/http/router/plugin.go:58–100  ·  view source on GitHub ↗
(c *gin.Context)

Source from the content-addressed store, hash-verified

56}
57
58func createPlugin(c *gin.Context) {
59 t, err := strconv.Atoi(c.PostForm("TYPE"))
60 if err != nil {
61 response.JSON(c, response.SetError(err))
62 return
63 }
64 u, err := strconv.Atoi(c.PostForm("USER"))
65 if err != nil {
66 response.JSON(c, response.SetError(err))
67 return
68 }
69 plugin := &metadbmodel.Plugin{
70 Name: c.PostForm("NAME"),
71 Type: t,
72 UserName: u,
73 }
74
75 // get file
76 file, _, err := c.Request.FormFile("IMAGE")
77 if err != nil {
78 response.JSON(c, response.SetError(err))
79 return
80 }
81 defer file.Close()
82 buf := bytes.NewBuffer(nil)
83 _, err = io.Copy(buf, file)
84 if err != nil {
85 response.JSON(c, response.SetError(err))
86 return
87 }
88 plugin.Image = buf.Bytes()
89
90 dbInfo, err := metadb.GetDB(httpcommon.GetUserInfo(c).ORGID)
91 if err != nil {
92 response.JSON(c, response.SetError(err))
93 return
94 }
95 data, err := service.CreatePlugin(dbInfo, plugin)
96 if err == nil {
97 refresh.RefreshCache(dbInfo.ORGID, []common.DataChanged{common.DATA_CHANGED_VTAP})
98 }
99 response.JSON(c, response.SetData(data), response.SetError(err))
100}
101
102func deletePlugin(c *gin.Context) {
103 dbInfo, err := metadb.GetDB(httpcommon.GetUserInfo(c).ORGID)

Callers

nothing calls this directly

Calls 6

JSONMethod · 0.80
GetUserInfoMethod · 0.80
CloseMethod · 0.65
CopyMethod · 0.45
BytesMethod · 0.45
GetDBMethod · 0.45

Tested by

no test coverage detected