repo.go 2.9 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124
  1. // SiYuan - Build Your Eternal Digital Garden
  2. // Copyright (c) 2020-present, b3log.org
  3. //
  4. // This program is free software: you can redistribute it and/or modify
  5. // it under the terms of the GNU Affero General Public License as published by
  6. // the Free Software Foundation, either version 3 of the License, or
  7. // (at your option) any later version.
  8. //
  9. // This program is distributed in the hope that it will be useful,
  10. // but WITHOUT ANY WARRANTY; without even the implied warranty of
  11. // MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE. See the
  12. // GNU Affero General Public License for more details.
  13. //
  14. // You should have received a copy of the GNU Affero General Public License
  15. // along with this program. If not, see <https://www.gnu.org/licenses/>.
  16. package api
  17. import (
  18. "encoding/hex"
  19. "fmt"
  20. "net/http"
  21. "time"
  22. "github.com/88250/gulu"
  23. "github.com/gin-gonic/gin"
  24. "github.com/siyuan-note/siyuan/kernel/model"
  25. "github.com/siyuan-note/siyuan/kernel/util"
  26. )
  27. func checkoutRepo(c *gin.Context) {
  28. ret := gulu.Ret.NewResult()
  29. defer c.JSON(http.StatusOK, ret)
  30. arg, ok := util.JsonArg(c, ret)
  31. if !ok {
  32. return
  33. }
  34. id := arg["id"].(string)
  35. if err := model.CheckoutRepo(id); nil != err {
  36. ret.Code = -1
  37. ret.Msg = model.Conf.Language(141)
  38. return
  39. }
  40. }
  41. func getRepoIndexLogs(c *gin.Context) {
  42. ret := gulu.Ret.NewResult()
  43. defer c.JSON(http.StatusOK, ret)
  44. arg, ok := util.JsonArg(c, ret)
  45. if !ok {
  46. return
  47. }
  48. page := arg["page"].(float64)
  49. logs, err := model.GetRepoIndexLogs(int(page))
  50. if nil != err {
  51. ret.Code = -1
  52. ret.Msg = err.Error()
  53. return
  54. }
  55. ret.Data = map[string]interface{}{
  56. "logs": logs,
  57. }
  58. }
  59. func indexRepo(c *gin.Context) {
  60. ret := gulu.Ret.NewResult()
  61. defer c.JSON(http.StatusOK, ret)
  62. arg, ok := util.JsonArg(c, ret)
  63. if !ok {
  64. return
  65. }
  66. message := arg["message"].(string)
  67. if err := model.IndexRepo(message); nil != err {
  68. ret.Code = -1
  69. ret.Msg = fmt.Sprintf(model.Conf.Language(140), err)
  70. ret.Data = map[string]interface{}{"closeTimeout": 5000}
  71. return
  72. }
  73. }
  74. func importRepoKey(c *gin.Context) {
  75. ret := gulu.Ret.NewResult()
  76. defer c.JSON(http.StatusOK, ret)
  77. arg, ok := util.JsonArg(c, ret)
  78. if !ok {
  79. return
  80. }
  81. msgId := util.PushMsg(model.Conf.Language(136), 1000*7)
  82. hexKey := arg["key"].(string)
  83. if err := model.ImportRepoKey(hexKey); nil != err {
  84. ret.Code = -1
  85. ret.Msg = model.Conf.Language(137)
  86. return
  87. }
  88. time.Sleep(1 * time.Second)
  89. util.PushUpdateMsg(msgId, model.Conf.Language(138), 3000)
  90. }
  91. func initRepoKey(c *gin.Context) {
  92. ret := gulu.Ret.NewResult()
  93. defer c.JSON(http.StatusOK, ret)
  94. msgId := util.PushMsg(model.Conf.Language(136), 1000*7)
  95. if err := model.InitRepoKey(); nil != err {
  96. ret.Code = -1
  97. ret.Msg = model.Conf.Language(137)
  98. return
  99. }
  100. time.Sleep(1 * time.Second)
  101. util.PushUpdateMsg(msgId, model.Conf.Language(138), 3000)
  102. ret.Data = map[string]interface{}{
  103. "key": hex.EncodeToString(model.Conf.Repo.Key),
  104. }
  105. }