main.go 4.1 KB

123456789101112131415161718192021222324252627282930313233343536373839404142434445464748495051525354555657585960616263646566676869707172737475767778798081828384858687888990919293949596979899100101102103104105106107108109110111112113114115116117118119120121122123124125126127128129130131132133134135136137138139140141142143144145146147148149150151152153154155156157158159160161162163164165166167168169170171172173174175176177178179180181182
  1. package main
  2. import (
  3. "bytes"
  4. "flag"
  5. "fmt"
  6. "os"
  7. "path/filepath"
  8. )
  9. func main() {
  10. root := flag.String("root", ".", "repository root containing internal/database/model and internal/web/entity")
  11. outDir := flag.String("out", "frontend/src/generated", "output directory relative to root")
  12. flag.Parse()
  13. if err := run(*root, *outDir); err != nil {
  14. fmt.Fprintln(os.Stderr, "openapigen:", err)
  15. os.Exit(1)
  16. }
  17. }
  18. func run(root, outDir string) error {
  19. requests := []packageRequest{
  20. {
  21. Path: resolveRel(root, "internal/database/model"),
  22. StructAllow: setOf(
  23. "User",
  24. "Inbound",
  25. "FallbackParentInfo",
  26. "OutboundTraffics",
  27. "InboundClientIps",
  28. "ApiToken",
  29. "HistoryOfSeeders",
  30. "Setting",
  31. "Node",
  32. "ClientReverse",
  33. "Client",
  34. "ClientRecord",
  35. "ClientInbound",
  36. "InboundFallback",
  37. "Host",
  38. "SubBalancer",
  39. ),
  40. AliasAllow: setOf("Protocol"),
  41. Overrides: map[string][]walkOverride{
  42. "Inbound": {
  43. {Field: "Settings", Kind: KindAny},
  44. {Field: "StreamSettings", Kind: KindAny},
  45. {Field: "Sniffing", Kind: KindAny},
  46. },
  47. "ClientRecord": {
  48. {Field: "Reverse", Kind: KindAny},
  49. },
  50. "InboundClientIps": {
  51. {Field: "Ips", Kind: KindAny},
  52. },
  53. "Host": {
  54. {Field: "MuxParams", Kind: KindAny},
  55. {Field: "SockoptParams", Kind: KindAny},
  56. },
  57. },
  58. },
  59. {
  60. Path: resolveRel(root, "internal/web/entity"),
  61. StructAllow: setOf(
  62. "Msg",
  63. "AllSetting",
  64. "AllSettingView",
  65. "HostGroup",
  66. ),
  67. },
  68. {
  69. Path: resolveRel(root, "internal/xray"),
  70. StructAllow: setOf(
  71. "ClientTraffic",
  72. "Traffic",
  73. ),
  74. },
  75. {
  76. Path: resolveRel(root, "internal/xray/geodata"),
  77. StructAllow: setOf(
  78. "GeoFile",
  79. "GeoCategory",
  80. "GeoEntry",
  81. "GeoCategoryPage",
  82. "GeoEntryPage",
  83. ),
  84. AliasAllow: setOf("GeoKind"),
  85. },
  86. {
  87. Path: resolveRel(root, "internal/web/service"),
  88. StructAllow: setOf(
  89. "InboundOption",
  90. "HappLinkResult",
  91. "ClientSlim",
  92. "ClientPageResponse",
  93. "ClientsSummary",
  94. "InboundTrafficSummary",
  95. "LogEntry",
  96. "NewUUIDResponse",
  97. "MLDSA65Response",
  98. "MLKEM768Response",
  99. "NodeMutationRequest",
  100. "NodeView",
  101. "ProbeResultUI",
  102. "RealityScanResult",
  103. "GeodataTokenIssue",
  104. "AmneziaWGLogs",
  105. "PeerActivity",
  106. "HwidSlotStatus",
  107. ),
  108. },
  109. {
  110. Path: resolveRel(root, "internal/web/service/panel"),
  111. StructAllow: setOf("ApiTokenView", "PanelUpdateStatus"),
  112. },
  113. {
  114. Path: resolveRel(root, "internal/amneziawg"),
  115. StructAllow: setOf("ServerSettings"),
  116. },
  117. {
  118. Path: resolveRel(root, "internal/tuic"),
  119. StructAllow: setOf("TuicServerSettings", "TuicClientSettings"),
  120. },
  121. }
  122. schemas, aliases, err := walkPackages(requests)
  123. if err != nil {
  124. return err
  125. }
  126. schemas = flattenEmbedded(schemas)
  127. if len(schemas) == 0 {
  128. return fmt.Errorf("no schemas produced; nothing to write")
  129. }
  130. target := filepath.Join(root, outDir)
  131. if err := os.MkdirAll(target, 0o755); err != nil {
  132. return err
  133. }
  134. zodBuf := &bytes.Buffer{}
  135. if err := emitZod(zodBuf, schemas, aliases); err != nil {
  136. return err
  137. }
  138. typesBuf := &bytes.Buffer{}
  139. if err := emitTypes(typesBuf, schemas, aliases); err != nil {
  140. return err
  141. }
  142. examplesBuf := &bytes.Buffer{}
  143. if err := emitExamples(examplesBuf, schemas, aliases); err != nil {
  144. return err
  145. }
  146. schemasBuf := &bytes.Buffer{}
  147. if err := emitJSONSchema(schemasBuf, schemas, aliases); err != nil {
  148. return err
  149. }
  150. if err := os.WriteFile(filepath.Join(target, "zod.ts"), zodBuf.Bytes(), 0o644); err != nil {
  151. return err
  152. }
  153. if err := os.WriteFile(filepath.Join(target, "types.ts"), typesBuf.Bytes(), 0o644); err != nil {
  154. return err
  155. }
  156. if err := os.WriteFile(filepath.Join(target, "examples.ts"), examplesBuf.Bytes(), 0o644); err != nil {
  157. return err
  158. }
  159. if err := os.WriteFile(filepath.Join(target, "schemas.ts"), schemasBuf.Bytes(), 0o644); err != nil {
  160. return err
  161. }
  162. fmt.Printf("openapigen: wrote %d schemas to %s\n", len(schemas), target)
  163. return nil
  164. }
  165. func setOf(names ...string) map[string]bool {
  166. m := make(map[string]bool, len(names))
  167. for _, n := range names {
  168. m[n] = true
  169. }
  170. return m
  171. }