| list{_, "metrics"} =>
| list{_, "metric", name} =>
+ | list{_, "errors"} =>
| _ =>
{"Not found"->str}
}}
diff --git a/web/src/components/Search.res b/web/src/components/Search.res
index b14cb4855..5e29d2ed7 100644
--- a/web/src/components/Search.res
+++ b/web/src/components/Search.res
@@ -399,6 +399,20 @@ module Top = {
None
}, [state.query])
+ // Update crawler error
+ let handleErrors = (resp: WebApi.axiosResponse
) =>
+ switch resp.data {
+ | CrawlerTypes.Success(errors_list) =>
+ SetErrors(errors_list.errors)->dispatch->Js.Promise.resolve
+ | CrawlerTypes.Error(err) => Js.Console.error(err)->Js.Promise.resolve
+ }
+
+ React.useEffect1(() => {
+ ({index: state.index, query: state.query}->WebApi.Crawler.errors
+ |> Js.Promise.then_(handleErrors))->ignore
+ None
+ }, [state.query])
+
// Dispatch the value upstream
let handleCheck = (newValue, res: WebApi.axiosResponse) => {
switch res.data {
diff --git a/web/src/components/Store.res b/web/src/components/Store.res
index 87afbe388..3a20f1c9c 100644
--- a/web/src/components/Store.res
+++ b/web/src/components/Store.res
@@ -66,6 +66,7 @@ module Store = {
about: ConfigTypes.about,
dexie: Dexie.Database.t,
toasts: list,
+ errors: list,
}
type action =
| ChangeIndex(string)
@@ -74,6 +75,7 @@ module Store = {
| SetLimit(int)
| SetOrder(option)
| SetAuthorScopedTab(authorScopedTab)
+ | SetErrors(list)
| FetchFields(fieldsRespR)
| FetchSuggestions(suggestionsR)
| FetchProjects(projectsR)
@@ -121,6 +123,7 @@ module Store = {
changes_pies_panel: false,
dexie: MonoIndexedDB.mkDexie(),
toasts: list{},
+ errors: list{},
}
let reducer = (state: t, action: action) =>
@@ -151,6 +154,7 @@ module Store = {
Prelude.setLocationSearch("l", limit->string_of_int)->ignore
{...state, limit: limit}
}
+ | SetErrors(errors) => {...state, errors: errors}
| FetchFields(res) => {...state, fields: res->RemoteData.fmap(resp => resp.fields)}
| FetchSuggestions(res) => {...state, suggestions: res}
| FetchProjects(res) => {...state, projects: res}
diff --git a/web/src/components/WebApi.res b/web/src/components/WebApi.res
index d2c3c198d..ed371730c 100644
--- a/web/src/components/WebApi.res
+++ b/web/src/components/WebApi.res
@@ -181,5 +181,42 @@ module Metric = {
}
module Crawler = {
+ @module("axios")
+ external addDocRaw: (string, 'a) => axios<'b> = "post"
+
+ let addDoc = (request: CrawlerTypes.add_doc_request): axios =>
+ request->CrawlerBs.encode_add_doc_request
+ |> addDocRaw(serverUrl ++ "/api/2/crawler/add")
+ |> Js.Promise.then_(resp =>
+ {data: resp.data->CrawlerBs.decode_add_doc_response}->Js.Promise.resolve
+ )
+ @module("axios")
+ external commitRaw: (string, 'a) => axios<'b> = "post"
+
+ let commit = (request: CrawlerTypes.commit_request): axios =>
+ request->CrawlerBs.encode_commit_request
+ |> commitRaw(serverUrl ++ "/api/2/crawler/commit")
+ |> Js.Promise.then_(resp =>
+ {data: resp.data->CrawlerBs.decode_commit_response}->Js.Promise.resolve
+ )
+ @module("axios")
+ external commitInfoRaw: (string, 'a) => axios<'b> = "post"
+
+ let commitInfo = (request: CrawlerTypes.commit_info_request): axios<
+ CrawlerTypes.commit_info_response,
+ > =>
+ request->CrawlerBs.encode_commit_info_request
+ |> commitInfoRaw(serverUrl ++ "/api/2/crawler/get_commit_info")
+ |> Js.Promise.then_(resp =>
+ {data: resp.data->CrawlerBs.decode_commit_info_response}->Js.Promise.resolve
+ )
+ @module("axios")
+ external errorsRaw: (string, 'a) => axios<'b> = "post"
+ let errors = (request: CrawlerTypes.errors_request): axios =>
+ request->CrawlerBs.encode_errors_request
+ |> errorsRaw(serverUrl ++ "/api/2/crawler/errors")
+ |> Js.Promise.then_(resp =>
+ {data: resp.data->CrawlerBs.decode_errors_response}->Js.Promise.resolve
+ )
}
diff --git a/web/src/messages/ChangeBs.ml b/web/src/messages/ChangeBs.ml
new file mode 100644
index 000000000..005f19aa0
--- /dev/null
+++ b/web/src/messages/ChangeBs.ml
@@ -0,0 +1,1109 @@
+[@@@ocaml.warning "-27-30-39"]
+
+type ident_mutable = {
+ mutable uid : string;
+ mutable muid : string;
+ mutable groups : string list;
+}
+
+let default_ident_mutable () : ident_mutable = {
+ uid = "";
+ muid = "";
+ groups = [];
+}
+
+type changed_file_mutable = {
+ mutable additions : int32;
+ mutable deletions : int32;
+ mutable path : string;
+}
+
+let default_changed_file_mutable () : changed_file_mutable = {
+ additions = 0l;
+ deletions = 0l;
+ path = "";
+}
+
+type changed_file_path_mutable = {
+ mutable path : string;
+}
+
+let default_changed_file_path_mutable () : changed_file_path_mutable = {
+ path = "";
+}
+
+type commit_mutable = {
+ mutable sha : string;
+ mutable author : ChangeTypes.ident option;
+ mutable committer : ChangeTypes.ident option;
+ mutable authored_at : TimestampTypes.timestamp option;
+ mutable committed_at : TimestampTypes.timestamp option;
+ mutable additions : int32;
+ mutable deletions : int32;
+ mutable title : string;
+}
+
+let default_commit_mutable () : commit_mutable = {
+ sha = "";
+ author = None;
+ committer = None;
+ authored_at = None;
+ committed_at = None;
+ additions = 0l;
+ deletions = 0l;
+ title = "";
+}
+
+type change_mutable = {
+ mutable id : string;
+ mutable number : int32;
+ mutable change_id : string;
+ mutable title : string;
+ mutable text : string;
+ mutable url : string;
+ mutable commit_count : int32;
+ mutable additions : int32;
+ mutable deletions : int32;
+ mutable changed_files_count : int32;
+ mutable changed_files : ChangeTypes.changed_file list;
+ mutable commits : ChangeTypes.commit list;
+ mutable repository_prefix : string;
+ mutable repository_fullname : string;
+ mutable repository_shortname : string;
+ mutable author : ChangeTypes.ident option;
+ mutable optional_merged_by : ChangeTypes.change_optional_merged_by;
+ mutable branch : string;
+ mutable target_branch : string;
+ mutable created_at : TimestampTypes.timestamp option;
+ mutable optional_merged_at : ChangeTypes.change_optional_merged_at;
+ mutable updated_at : TimestampTypes.timestamp option;
+ mutable optional_closed_at : ChangeTypes.change_optional_closed_at;
+ mutable state : ChangeTypes.change_change_state;
+ mutable optional_duration : ChangeTypes.change_optional_duration;
+ mutable mergeable : string;
+ mutable labels : string list;
+ mutable assignees : ChangeTypes.ident list;
+ mutable approvals : string list;
+ mutable draft : bool;
+ mutable optional_self_merged : ChangeTypes.change_optional_self_merged;
+ mutable optional_merged_commit_sha : ChangeTypes.change_optional_merged_commit_sha;
+}
+
+let default_change_mutable () : change_mutable = {
+ id = "";
+ number = 0l;
+ change_id = "";
+ title = "";
+ text = "";
+ url = "";
+ commit_count = 0l;
+ additions = 0l;
+ deletions = 0l;
+ changed_files_count = 0l;
+ changed_files = [];
+ commits = [];
+ repository_prefix = "";
+ repository_fullname = "";
+ repository_shortname = "";
+ author = None;
+ optional_merged_by = ChangeTypes.Merged_by (ChangeTypes.default_ident ());
+ branch = "";
+ target_branch = "";
+ created_at = None;
+ optional_merged_at = ChangeTypes.Merged_at (TimestampTypes.default_timestamp);
+ updated_at = None;
+ optional_closed_at = ChangeTypes.Closed_at (TimestampTypes.default_timestamp);
+ state = ChangeTypes.default_change_change_state ();
+ optional_duration = ChangeTypes.Duration (0l);
+ mergeable = "";
+ labels = [];
+ assignees = [];
+ approvals = [];
+ draft = false;
+ optional_self_merged = ChangeTypes.Self_merged (false);
+ optional_merged_commit_sha = ChangeTypes.Merged_commit_sha ("");
+}
+
+type change_reviewed_event_mutable = {
+ mutable approvals : string list;
+}
+
+let default_change_reviewed_event_mutable () : change_reviewed_event_mutable = {
+ approvals = [];
+}
+
+type change_event_mutable = {
+ mutable id : string;
+ mutable created_at : TimestampTypes.timestamp option;
+ mutable author : ChangeTypes.ident option;
+ mutable repository_prefix : string;
+ mutable repository_fullname : string;
+ mutable repository_shortname : string;
+ mutable branch : string;
+ mutable target_branch : string;
+ mutable number : int32;
+ mutable change_id : string;
+ mutable url : string;
+ mutable on_author : ChangeTypes.ident option;
+ mutable on_created_at : TimestampTypes.timestamp option;
+ mutable changed_files : ChangeTypes.changed_file_path list;
+ mutable type_ : ChangeTypes.change_event_type;
+ mutable labels : string list;
+ mutable optional_duration : ChangeTypes.change_event_optional_duration;
+ mutable draft : bool;
+ mutable optional_merged_commit_sha : ChangeTypes.change_event_optional_merged_commit_sha;
+}
+
+let default_change_event_mutable () : change_event_mutable = {
+ id = "";
+ created_at = None;
+ author = None;
+ repository_prefix = "";
+ repository_fullname = "";
+ repository_shortname = "";
+ branch = "";
+ target_branch = "";
+ number = 0l;
+ change_id = "";
+ url = "";
+ on_author = None;
+ on_created_at = None;
+ changed_files = [];
+ type_ = ChangeTypes.Change_created;
+ labels = [];
+ optional_duration = ChangeTypes.Duration (0l);
+ draft = false;
+ optional_merged_commit_sha = ChangeTypes.Merged_commit_sha ("");
+}
+
+
+let rec decode_ident json =
+ let v = default_ident_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "uid" ->
+ let json = Js.Dict.unsafeGet json "uid" in
+ v.uid <- Pbrt_bs.string json "ident" "uid"
+ | "muid" ->
+ let json = Js.Dict.unsafeGet json "muid" in
+ v.muid <- Pbrt_bs.string json "ident" "muid"
+ | "groups" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "groups" in
+ Pbrt_bs.array_ a "ident" "groups"
+ in
+ v.groups <- Array.map (fun json ->
+ Pbrt_bs.string json "ident" "groups"
+ ) a |> Array.to_list;
+ end
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ ChangeTypes.uid = v.uid;
+ ChangeTypes.muid = v.muid;
+ ChangeTypes.groups = v.groups;
+ } : ChangeTypes.ident)
+
+let rec decode_changed_file json =
+ let v = default_changed_file_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "additions" ->
+ let json = Js.Dict.unsafeGet json "additions" in
+ v.additions <- Pbrt_bs.int32 json "changed_file" "additions"
+ | "deletions" ->
+ let json = Js.Dict.unsafeGet json "deletions" in
+ v.deletions <- Pbrt_bs.int32 json "changed_file" "deletions"
+ | "path" ->
+ let json = Js.Dict.unsafeGet json "path" in
+ v.path <- Pbrt_bs.string json "changed_file" "path"
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ ChangeTypes.additions = v.additions;
+ ChangeTypes.deletions = v.deletions;
+ ChangeTypes.path = v.path;
+ } : ChangeTypes.changed_file)
+
+let rec decode_changed_file_path json =
+ let v = default_changed_file_path_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "path" ->
+ let json = Js.Dict.unsafeGet json "path" in
+ v.path <- Pbrt_bs.string json "changed_file_path" "path"
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ ChangeTypes.path = v.path;
+ } : ChangeTypes.changed_file_path)
+
+let rec decode_commit json =
+ let v = default_commit_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "sha" ->
+ let json = Js.Dict.unsafeGet json "sha" in
+ v.sha <- Pbrt_bs.string json "commit" "sha"
+ | "author" ->
+ let json = Js.Dict.unsafeGet json "author" in
+ v.author <- Some ((decode_ident (Pbrt_bs.object_ json "commit" "author")))
+ | "committer" ->
+ let json = Js.Dict.unsafeGet json "committer" in
+ v.committer <- Some ((decode_ident (Pbrt_bs.object_ json "commit" "committer")))
+ | "authored_at" ->
+ let json = Js.Dict.unsafeGet json "authored_at" in
+ v.authored_at <- Some ((TimestampBs.decode_timestamp (Pbrt_bs.string json "commit" "authored_at")))
+ | "committed_at" ->
+ let json = Js.Dict.unsafeGet json "committed_at" in
+ v.committed_at <- Some ((TimestampBs.decode_timestamp (Pbrt_bs.string json "commit" "committed_at")))
+ | "additions" ->
+ let json = Js.Dict.unsafeGet json "additions" in
+ v.additions <- Pbrt_bs.int32 json "commit" "additions"
+ | "deletions" ->
+ let json = Js.Dict.unsafeGet json "deletions" in
+ v.deletions <- Pbrt_bs.int32 json "commit" "deletions"
+ | "title" ->
+ let json = Js.Dict.unsafeGet json "title" in
+ v.title <- Pbrt_bs.string json "commit" "title"
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ ChangeTypes.sha = v.sha;
+ ChangeTypes.author = v.author;
+ ChangeTypes.committer = v.committer;
+ ChangeTypes.authored_at = v.authored_at;
+ ChangeTypes.committed_at = v.committed_at;
+ ChangeTypes.additions = v.additions;
+ ChangeTypes.deletions = v.deletions;
+ ChangeTypes.title = v.title;
+ } : ChangeTypes.commit)
+
+let rec decode_change_change_state (json:Js.Json.t) =
+ match Pbrt_bs.string json "change_change_state" "value" with
+ | "Open" -> (ChangeTypes.Open : ChangeTypes.change_change_state)
+ | "Merged" -> (ChangeTypes.Merged : ChangeTypes.change_change_state)
+ | "Closed" -> (ChangeTypes.Closed : ChangeTypes.change_change_state)
+ | "" -> ChangeTypes.Open
+ | _ -> Pbrt_bs.E.malformed_variant "change_change_state"
+
+let rec decode_change_optional_merged_by json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "change_optional_merged_by"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "merged_by" ->
+ let json = Js.Dict.unsafeGet json "merged_by" in
+ (ChangeTypes.Merged_by ((decode_ident (Pbrt_bs.object_ json "change_optional_merged_by" "Merged_by"))) : ChangeTypes.change_optional_merged_by)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+and decode_change_optional_merged_at json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "change_optional_merged_at"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "merged_at" ->
+ let json = Js.Dict.unsafeGet json "merged_at" in
+ (ChangeTypes.Merged_at ((TimestampBs.decode_timestamp (Pbrt_bs.string json "change_optional_merged_at" "Merged_at"))) : ChangeTypes.change_optional_merged_at)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+and decode_change_optional_closed_at json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "change_optional_closed_at"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "closed_at" ->
+ let json = Js.Dict.unsafeGet json "closed_at" in
+ (ChangeTypes.Closed_at ((TimestampBs.decode_timestamp (Pbrt_bs.string json "change_optional_closed_at" "Closed_at"))) : ChangeTypes.change_optional_closed_at)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+and decode_change_optional_duration json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "change_optional_duration"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "duration" ->
+ let json = Js.Dict.unsafeGet json "duration" in
+ (ChangeTypes.Duration (Pbrt_bs.int32 json "change_optional_duration" "Duration") : ChangeTypes.change_optional_duration)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+and decode_change_optional_self_merged json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "change_optional_self_merged"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "self_merged" ->
+ let json = Js.Dict.unsafeGet json "self_merged" in
+ (ChangeTypes.Self_merged (Pbrt_bs.bool json "change_optional_self_merged" "Self_merged") : ChangeTypes.change_optional_self_merged)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+and decode_change_optional_merged_commit_sha json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "change_optional_merged_commit_sha"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "merged_commitSha" ->
+ let json = Js.Dict.unsafeGet json "merged_commitSha" in
+ (ChangeTypes.Merged_commit_sha (Pbrt_bs.string json "change_optional_merged_commit_sha" "Merged_commit_sha") : ChangeTypes.change_optional_merged_commit_sha)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+and decode_change json =
+ let v = default_change_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "id" ->
+ let json = Js.Dict.unsafeGet json "id" in
+ v.id <- Pbrt_bs.string json "change" "id"
+ | "number" ->
+ let json = Js.Dict.unsafeGet json "number" in
+ v.number <- Pbrt_bs.int32 json "change" "number"
+ | "change_id" ->
+ let json = Js.Dict.unsafeGet json "change_id" in
+ v.change_id <- Pbrt_bs.string json "change" "change_id"
+ | "title" ->
+ let json = Js.Dict.unsafeGet json "title" in
+ v.title <- Pbrt_bs.string json "change" "title"
+ | "text" ->
+ let json = Js.Dict.unsafeGet json "text" in
+ v.text <- Pbrt_bs.string json "change" "text"
+ | "url" ->
+ let json = Js.Dict.unsafeGet json "url" in
+ v.url <- Pbrt_bs.string json "change" "url"
+ | "commit_count" ->
+ let json = Js.Dict.unsafeGet json "commit_count" in
+ v.commit_count <- Pbrt_bs.int32 json "change" "commit_count"
+ | "additions" ->
+ let json = Js.Dict.unsafeGet json "additions" in
+ v.additions <- Pbrt_bs.int32 json "change" "additions"
+ | "deletions" ->
+ let json = Js.Dict.unsafeGet json "deletions" in
+ v.deletions <- Pbrt_bs.int32 json "change" "deletions"
+ | "changed_files_count" ->
+ let json = Js.Dict.unsafeGet json "changed_files_count" in
+ v.changed_files_count <- Pbrt_bs.int32 json "change" "changed_files_count"
+ | "changed_files" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "changed_files" in
+ Pbrt_bs.array_ a "change" "changed_files"
+ in
+ v.changed_files <- Array.map (fun json ->
+ (decode_changed_file (Pbrt_bs.object_ json "change" "changed_files"))
+ ) a |> Array.to_list;
+ end
+ | "commits" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "commits" in
+ Pbrt_bs.array_ a "change" "commits"
+ in
+ v.commits <- Array.map (fun json ->
+ (decode_commit (Pbrt_bs.object_ json "change" "commits"))
+ ) a |> Array.to_list;
+ end
+ | "repository_prefix" ->
+ let json = Js.Dict.unsafeGet json "repository_prefix" in
+ v.repository_prefix <- Pbrt_bs.string json "change" "repository_prefix"
+ | "repository_fullname" ->
+ let json = Js.Dict.unsafeGet json "repository_fullname" in
+ v.repository_fullname <- Pbrt_bs.string json "change" "repository_fullname"
+ | "repository_shortname" ->
+ let json = Js.Dict.unsafeGet json "repository_shortname" in
+ v.repository_shortname <- Pbrt_bs.string json "change" "repository_shortname"
+ | "author" ->
+ let json = Js.Dict.unsafeGet json "author" in
+ v.author <- Some ((decode_ident (Pbrt_bs.object_ json "change" "author")))
+ | "merged_by" ->
+ let json = Js.Dict.unsafeGet json "merged_by" in
+ v.optional_merged_by <- Merged_by ((decode_ident (Pbrt_bs.object_ json "change" "optional_merged_by")))
+ | "branch" ->
+ let json = Js.Dict.unsafeGet json "branch" in
+ v.branch <- Pbrt_bs.string json "change" "branch"
+ | "target_branch" ->
+ let json = Js.Dict.unsafeGet json "target_branch" in
+ v.target_branch <- Pbrt_bs.string json "change" "target_branch"
+ | "created_at" ->
+ let json = Js.Dict.unsafeGet json "created_at" in
+ v.created_at <- Some ((TimestampBs.decode_timestamp (Pbrt_bs.string json "change" "created_at")))
+ | "merged_at" ->
+ let json = Js.Dict.unsafeGet json "merged_at" in
+ v.optional_merged_at <- Merged_at ((TimestampBs.decode_timestamp (Pbrt_bs.string json "change" "optional_merged_at")))
+ | "updated_at" ->
+ let json = Js.Dict.unsafeGet json "updated_at" in
+ v.updated_at <- Some ((TimestampBs.decode_timestamp (Pbrt_bs.string json "change" "updated_at")))
+ | "closed_at" ->
+ let json = Js.Dict.unsafeGet json "closed_at" in
+ v.optional_closed_at <- Closed_at ((TimestampBs.decode_timestamp (Pbrt_bs.string json "change" "optional_closed_at")))
+ | "state" ->
+ let json = Js.Dict.unsafeGet json "state" in
+ v.state <- (decode_change_change_state json)
+ | "duration" ->
+ let json = Js.Dict.unsafeGet json "duration" in
+ v.optional_duration <- Duration (Pbrt_bs.int32 json "change" "optional_duration")
+ | "mergeable" ->
+ let json = Js.Dict.unsafeGet json "mergeable" in
+ v.mergeable <- Pbrt_bs.string json "change" "mergeable"
+ | "labels" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "labels" in
+ Pbrt_bs.array_ a "change" "labels"
+ in
+ v.labels <- Array.map (fun json ->
+ Pbrt_bs.string json "change" "labels"
+ ) a |> Array.to_list;
+ end
+ | "assignees" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "assignees" in
+ Pbrt_bs.array_ a "change" "assignees"
+ in
+ v.assignees <- Array.map (fun json ->
+ (decode_ident (Pbrt_bs.object_ json "change" "assignees"))
+ ) a |> Array.to_list;
+ end
+ | "approvals" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "approvals" in
+ Pbrt_bs.array_ a "change" "approvals"
+ in
+ v.approvals <- Array.map (fun json ->
+ Pbrt_bs.string json "change" "approvals"
+ ) a |> Array.to_list;
+ end
+ | "draft" ->
+ let json = Js.Dict.unsafeGet json "draft" in
+ v.draft <- Pbrt_bs.bool json "change" "draft"
+ | "self_merged" ->
+ let json = Js.Dict.unsafeGet json "self_merged" in
+ v.optional_self_merged <- Self_merged (Pbrt_bs.bool json "change" "optional_self_merged")
+ | "merged_commitSha" ->
+ let json = Js.Dict.unsafeGet json "merged_commitSha" in
+ v.optional_merged_commit_sha <- Merged_commit_sha (Pbrt_bs.string json "change" "optional_merged_commit_sha")
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ ChangeTypes.id = v.id;
+ ChangeTypes.number = v.number;
+ ChangeTypes.change_id = v.change_id;
+ ChangeTypes.title = v.title;
+ ChangeTypes.text = v.text;
+ ChangeTypes.url = v.url;
+ ChangeTypes.commit_count = v.commit_count;
+ ChangeTypes.additions = v.additions;
+ ChangeTypes.deletions = v.deletions;
+ ChangeTypes.changed_files_count = v.changed_files_count;
+ ChangeTypes.changed_files = v.changed_files;
+ ChangeTypes.commits = v.commits;
+ ChangeTypes.repository_prefix = v.repository_prefix;
+ ChangeTypes.repository_fullname = v.repository_fullname;
+ ChangeTypes.repository_shortname = v.repository_shortname;
+ ChangeTypes.author = v.author;
+ ChangeTypes.optional_merged_by = v.optional_merged_by;
+ ChangeTypes.branch = v.branch;
+ ChangeTypes.target_branch = v.target_branch;
+ ChangeTypes.created_at = v.created_at;
+ ChangeTypes.optional_merged_at = v.optional_merged_at;
+ ChangeTypes.updated_at = v.updated_at;
+ ChangeTypes.optional_closed_at = v.optional_closed_at;
+ ChangeTypes.state = v.state;
+ ChangeTypes.optional_duration = v.optional_duration;
+ ChangeTypes.mergeable = v.mergeable;
+ ChangeTypes.labels = v.labels;
+ ChangeTypes.assignees = v.assignees;
+ ChangeTypes.approvals = v.approvals;
+ ChangeTypes.draft = v.draft;
+ ChangeTypes.optional_self_merged = v.optional_self_merged;
+ ChangeTypes.optional_merged_commit_sha = v.optional_merged_commit_sha;
+ } : ChangeTypes.change)
+
+let rec decode_change_reviewed_event json =
+ let v = default_change_reviewed_event_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "approvals" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "approvals" in
+ Pbrt_bs.array_ a "change_reviewed_event" "approvals"
+ in
+ v.approvals <- Array.map (fun json ->
+ Pbrt_bs.string json "change_reviewed_event" "approvals"
+ ) a |> Array.to_list;
+ end
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ ChangeTypes.approvals = v.approvals;
+ } : ChangeTypes.change_reviewed_event)
+
+let rec decode_change_event_type json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "change_event_type"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "change_created" -> (ChangeTypes.Change_created : ChangeTypes.change_event_type)
+ | "change_commented" -> (ChangeTypes.Change_commented : ChangeTypes.change_event_type)
+ | "change_abandoned" -> (ChangeTypes.Change_abandoned : ChangeTypes.change_event_type)
+ | "change_reviewed" ->
+ let json = Js.Dict.unsafeGet json "change_reviewed" in
+ (ChangeTypes.Change_reviewed ((decode_change_reviewed_event (Pbrt_bs.object_ json "change_event_type" "Change_reviewed"))) : ChangeTypes.change_event_type)
+ | "change_commitForcePushed" -> (ChangeTypes.Change_commit_force_pushed : ChangeTypes.change_event_type)
+ | "change_commitPushed" -> (ChangeTypes.Change_commit_pushed : ChangeTypes.change_event_type)
+ | "change_merged" -> (ChangeTypes.Change_merged : ChangeTypes.change_event_type)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+and decode_change_event_optional_duration json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "change_event_optional_duration"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "duration" ->
+ let json = Js.Dict.unsafeGet json "duration" in
+ (ChangeTypes.Duration (Pbrt_bs.int32 json "change_event_optional_duration" "Duration") : ChangeTypes.change_event_optional_duration)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+and decode_change_event_optional_merged_commit_sha json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "change_event_optional_merged_commit_sha"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "merged_commitSha" ->
+ let json = Js.Dict.unsafeGet json "merged_commitSha" in
+ (ChangeTypes.Merged_commit_sha (Pbrt_bs.string json "change_event_optional_merged_commit_sha" "Merged_commit_sha") : ChangeTypes.change_event_optional_merged_commit_sha)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+and decode_change_event json =
+ let v = default_change_event_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "id" ->
+ let json = Js.Dict.unsafeGet json "id" in
+ v.id <- Pbrt_bs.string json "change_event" "id"
+ | "created_at" ->
+ let json = Js.Dict.unsafeGet json "created_at" in
+ v.created_at <- Some ((TimestampBs.decode_timestamp (Pbrt_bs.string json "change_event" "created_at")))
+ | "author" ->
+ let json = Js.Dict.unsafeGet json "author" in
+ v.author <- Some ((decode_ident (Pbrt_bs.object_ json "change_event" "author")))
+ | "repository_prefix" ->
+ let json = Js.Dict.unsafeGet json "repository_prefix" in
+ v.repository_prefix <- Pbrt_bs.string json "change_event" "repository_prefix"
+ | "repository_fullname" ->
+ let json = Js.Dict.unsafeGet json "repository_fullname" in
+ v.repository_fullname <- Pbrt_bs.string json "change_event" "repository_fullname"
+ | "repository_shortname" ->
+ let json = Js.Dict.unsafeGet json "repository_shortname" in
+ v.repository_shortname <- Pbrt_bs.string json "change_event" "repository_shortname"
+ | "branch" ->
+ let json = Js.Dict.unsafeGet json "branch" in
+ v.branch <- Pbrt_bs.string json "change_event" "branch"
+ | "target_branch" ->
+ let json = Js.Dict.unsafeGet json "target_branch" in
+ v.target_branch <- Pbrt_bs.string json "change_event" "target_branch"
+ | "number" ->
+ let json = Js.Dict.unsafeGet json "number" in
+ v.number <- Pbrt_bs.int32 json "change_event" "number"
+ | "change_id" ->
+ let json = Js.Dict.unsafeGet json "change_id" in
+ v.change_id <- Pbrt_bs.string json "change_event" "change_id"
+ | "url" ->
+ let json = Js.Dict.unsafeGet json "url" in
+ v.url <- Pbrt_bs.string json "change_event" "url"
+ | "on_author" ->
+ let json = Js.Dict.unsafeGet json "on_author" in
+ v.on_author <- Some ((decode_ident (Pbrt_bs.object_ json "change_event" "on_author")))
+ | "on_created_at" ->
+ let json = Js.Dict.unsafeGet json "on_created_at" in
+ v.on_created_at <- Some ((TimestampBs.decode_timestamp (Pbrt_bs.string json "change_event" "on_created_at")))
+ | "changed_files" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "changed_files" in
+ Pbrt_bs.array_ a "change_event" "changed_files"
+ in
+ v.changed_files <- Array.map (fun json ->
+ (decode_changed_file_path (Pbrt_bs.object_ json "change_event" "changed_files"))
+ ) a |> Array.to_list;
+ end
+ | "change_created" -> v.type_ <- Change_created
+ | "change_commented" -> v.type_ <- Change_commented
+ | "change_abandoned" -> v.type_ <- Change_abandoned
+ | "change_reviewed" ->
+ let json = Js.Dict.unsafeGet json "change_reviewed" in
+ v.type_ <- Change_reviewed ((decode_change_reviewed_event (Pbrt_bs.object_ json "change_event" "type_")))
+ | "change_commitForcePushed" -> v.type_ <- Change_commit_force_pushed
+ | "change_commitPushed" -> v.type_ <- Change_commit_pushed
+ | "change_merged" -> v.type_ <- Change_merged
+ | "labels" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "labels" in
+ Pbrt_bs.array_ a "change_event" "labels"
+ in
+ v.labels <- Array.map (fun json ->
+ Pbrt_bs.string json "change_event" "labels"
+ ) a |> Array.to_list;
+ end
+ | "duration" ->
+ let json = Js.Dict.unsafeGet json "duration" in
+ v.optional_duration <- Duration (Pbrt_bs.int32 json "change_event" "optional_duration")
+ | "draft" ->
+ let json = Js.Dict.unsafeGet json "draft" in
+ v.draft <- Pbrt_bs.bool json "change_event" "draft"
+ | "merged_commitSha" ->
+ let json = Js.Dict.unsafeGet json "merged_commitSha" in
+ v.optional_merged_commit_sha <- Merged_commit_sha (Pbrt_bs.string json "change_event" "optional_merged_commit_sha")
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ ChangeTypes.id = v.id;
+ ChangeTypes.created_at = v.created_at;
+ ChangeTypes.author = v.author;
+ ChangeTypes.repository_prefix = v.repository_prefix;
+ ChangeTypes.repository_fullname = v.repository_fullname;
+ ChangeTypes.repository_shortname = v.repository_shortname;
+ ChangeTypes.branch = v.branch;
+ ChangeTypes.target_branch = v.target_branch;
+ ChangeTypes.number = v.number;
+ ChangeTypes.change_id = v.change_id;
+ ChangeTypes.url = v.url;
+ ChangeTypes.on_author = v.on_author;
+ ChangeTypes.on_created_at = v.on_created_at;
+ ChangeTypes.changed_files = v.changed_files;
+ ChangeTypes.type_ = v.type_;
+ ChangeTypes.labels = v.labels;
+ ChangeTypes.optional_duration = v.optional_duration;
+ ChangeTypes.draft = v.draft;
+ ChangeTypes.optional_merged_commit_sha = v.optional_merged_commit_sha;
+ } : ChangeTypes.change_event)
+
+let rec encode_ident (v:ChangeTypes.ident) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "uid" (Js.Json.string v.ChangeTypes.uid);
+ Js.Dict.set json "muid" (Js.Json.string v.ChangeTypes.muid);
+ let a = v.ChangeTypes.groups |> Array.of_list |> Array.map Js.Json.string in
+ Js.Dict.set json "groups" (Js.Json.array a);
+ json
+
+let rec encode_changed_file (v:ChangeTypes.changed_file) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "additions" (Js.Json.number (Int32.to_float v.ChangeTypes.additions));
+ Js.Dict.set json "deletions" (Js.Json.number (Int32.to_float v.ChangeTypes.deletions));
+ Js.Dict.set json "path" (Js.Json.string v.ChangeTypes.path);
+ json
+
+let rec encode_changed_file_path (v:ChangeTypes.changed_file_path) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "path" (Js.Json.string v.ChangeTypes.path);
+ json
+
+let rec encode_commit (v:ChangeTypes.commit) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "sha" (Js.Json.string v.ChangeTypes.sha);
+ begin match v.ChangeTypes.author with
+ | None -> ()
+ | Some v ->
+ begin (* author field *)
+ let json' = encode_ident v in
+ Js.Dict.set json "author" (Js.Json.object_ json');
+ end;
+ end;
+ begin match v.ChangeTypes.committer with
+ | None -> ()
+ | Some v ->
+ begin (* committer field *)
+ let json' = encode_ident v in
+ Js.Dict.set json "committer" (Js.Json.object_ json');
+ end;
+ end;
+ begin match v.ChangeTypes.authored_at with
+ | None -> ()
+ | Some v ->
+ begin (* authored_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "authored_at" (Js.Json.string json');
+ end;
+ end;
+ begin match v.ChangeTypes.committed_at with
+ | None -> ()
+ | Some v ->
+ begin (* committed_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "committed_at" (Js.Json.string json');
+ end;
+ end;
+ Js.Dict.set json "additions" (Js.Json.number (Int32.to_float v.ChangeTypes.additions));
+ Js.Dict.set json "deletions" (Js.Json.number (Int32.to_float v.ChangeTypes.deletions));
+ Js.Dict.set json "title" (Js.Json.string v.ChangeTypes.title);
+ json
+
+let rec encode_change_change_state (v:ChangeTypes.change_change_state) : string =
+ match v with
+ | ChangeTypes.Open -> "Open"
+ | ChangeTypes.Merged -> "Merged"
+ | ChangeTypes.Closed -> "Closed"
+
+let rec encode_change_optional_merged_by (v:ChangeTypes.change_optional_merged_by) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | ChangeTypes.Merged_by v ->
+ begin (* mergedBy field *)
+ let json' = encode_ident v in
+ Js.Dict.set json "merged_by" (Js.Json.object_ json');
+ end;
+ end;
+ json
+
+and encode_change_optional_merged_at (v:ChangeTypes.change_optional_merged_at) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | ChangeTypes.Merged_at v ->
+ begin (* merged_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "merged_at" (Js.Json.string json');
+ end;
+ end;
+ json
+
+and encode_change_optional_closed_at (v:ChangeTypes.change_optional_closed_at) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | ChangeTypes.Closed_at v ->
+ begin (* closed_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "closed_at" (Js.Json.string json');
+ end;
+ end;
+ json
+
+and encode_change_optional_duration (v:ChangeTypes.change_optional_duration) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | ChangeTypes.Duration v ->
+ Js.Dict.set json "duration" (Js.Json.number (Int32.to_float v));
+ end;
+ json
+
+and encode_change_optional_self_merged (v:ChangeTypes.change_optional_self_merged) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | ChangeTypes.Self_merged v ->
+ Js.Dict.set json "self_merged" (Js.Json.boolean v);
+ end;
+ json
+
+and encode_change_optional_merged_commit_sha (v:ChangeTypes.change_optional_merged_commit_sha) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | ChangeTypes.Merged_commit_sha v ->
+ Js.Dict.set json "merged_commitSha" (Js.Json.string v);
+ end;
+ json
+
+and encode_change (v:ChangeTypes.change) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "id" (Js.Json.string v.ChangeTypes.id);
+ Js.Dict.set json "number" (Js.Json.number (Int32.to_float v.ChangeTypes.number));
+ Js.Dict.set json "change_id" (Js.Json.string v.ChangeTypes.change_id);
+ Js.Dict.set json "title" (Js.Json.string v.ChangeTypes.title);
+ Js.Dict.set json "text" (Js.Json.string v.ChangeTypes.text);
+ Js.Dict.set json "url" (Js.Json.string v.ChangeTypes.url);
+ Js.Dict.set json "commit_count" (Js.Json.number (Int32.to_float v.ChangeTypes.commit_count));
+ Js.Dict.set json "additions" (Js.Json.number (Int32.to_float v.ChangeTypes.additions));
+ Js.Dict.set json "deletions" (Js.Json.number (Int32.to_float v.ChangeTypes.deletions));
+ Js.Dict.set json "changed_files_count" (Js.Json.number (Int32.to_float v.ChangeTypes.changed_files_count));
+ begin (* changedFiles field *)
+ let (changed_files':Js.Json.t) =
+ v.ChangeTypes.changed_files
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> encode_changed_file |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "changed_files" changed_files';
+ end;
+ begin (* commits field *)
+ let (commits':Js.Json.t) =
+ v.ChangeTypes.commits
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> encode_commit |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "commits" commits';
+ end;
+ Js.Dict.set json "repository_prefix" (Js.Json.string v.ChangeTypes.repository_prefix);
+ Js.Dict.set json "repository_fullname" (Js.Json.string v.ChangeTypes.repository_fullname);
+ Js.Dict.set json "repository_shortname" (Js.Json.string v.ChangeTypes.repository_shortname);
+ begin match v.ChangeTypes.author with
+ | None -> ()
+ | Some v ->
+ begin (* author field *)
+ let json' = encode_ident v in
+ Js.Dict.set json "author" (Js.Json.object_ json');
+ end;
+ end;
+ begin match v.ChangeTypes.optional_merged_by with
+ | Merged_by v ->
+ begin (* mergedBy field *)
+ let json' = encode_ident v in
+ Js.Dict.set json "merged_by" (Js.Json.object_ json');
+ end;
+ end; (* match v.optional_merged_by *)
+ Js.Dict.set json "branch" (Js.Json.string v.ChangeTypes.branch);
+ Js.Dict.set json "target_branch" (Js.Json.string v.ChangeTypes.target_branch);
+ begin match v.ChangeTypes.created_at with
+ | None -> ()
+ | Some v ->
+ begin (* created_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "created_at" (Js.Json.string json');
+ end;
+ end;
+ begin match v.ChangeTypes.optional_merged_at with
+ | Merged_at v ->
+ begin (* merged_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "merged_at" (Js.Json.string json');
+ end;
+ end; (* match v.optional_merged_at *)
+ begin match v.ChangeTypes.updated_at with
+ | None -> ()
+ | Some v ->
+ begin (* updated_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "updated_at" (Js.Json.string json');
+ end;
+ end;
+ begin match v.ChangeTypes.optional_closed_at with
+ | Closed_at v ->
+ begin (* closed_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "closed_at" (Js.Json.string json');
+ end;
+ end; (* match v.optional_closed_at *)
+ Js.Dict.set json "state" (Js.Json.string (encode_change_change_state v.ChangeTypes.state));
+ begin match v.ChangeTypes.optional_duration with
+ | Duration v ->
+ Js.Dict.set json "duration" (Js.Json.number (Int32.to_float v));
+ end; (* match v.optional_duration *)
+ Js.Dict.set json "mergeable" (Js.Json.string v.ChangeTypes.mergeable);
+ let a = v.ChangeTypes.labels |> Array.of_list |> Array.map Js.Json.string in
+ Js.Dict.set json "labels" (Js.Json.array a);
+ begin (* assignees field *)
+ let (assignees':Js.Json.t) =
+ v.ChangeTypes.assignees
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> encode_ident |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "assignees" assignees';
+ end;
+ let a = v.ChangeTypes.approvals |> Array.of_list |> Array.map Js.Json.string in
+ Js.Dict.set json "approvals" (Js.Json.array a);
+ Js.Dict.set json "draft" (Js.Json.boolean v.ChangeTypes.draft);
+ begin match v.ChangeTypes.optional_self_merged with
+ | Self_merged v ->
+ Js.Dict.set json "self_merged" (Js.Json.boolean v);
+ end; (* match v.optional_self_merged *)
+ begin match v.ChangeTypes.optional_merged_commit_sha with
+ | Merged_commit_sha v ->
+ Js.Dict.set json "merged_commitSha" (Js.Json.string v);
+ end; (* match v.optional_merged_commit_sha *)
+ json
+
+let rec encode_change_reviewed_event (v:ChangeTypes.change_reviewed_event) =
+ let json = Js.Dict.empty () in
+ let a = v.ChangeTypes.approvals |> Array.of_list |> Array.map Js.Json.string in
+ Js.Dict.set json "approvals" (Js.Json.array a);
+ json
+
+let rec encode_change_event_type (v:ChangeTypes.change_event_type) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | ChangeTypes.Change_created ->
+ Js.Dict.set json "change_created" Js.Json.null
+ | ChangeTypes.Change_commented ->
+ Js.Dict.set json "change_commented" Js.Json.null
+ | ChangeTypes.Change_abandoned ->
+ Js.Dict.set json "change_abandoned" Js.Json.null
+ | ChangeTypes.Change_reviewed v ->
+ begin (* changeReviewed field *)
+ let json' = encode_change_reviewed_event v in
+ Js.Dict.set json "change_reviewed" (Js.Json.object_ json');
+ end;
+ | ChangeTypes.Change_commit_force_pushed ->
+ Js.Dict.set json "change_commitForcePushed" Js.Json.null
+ | ChangeTypes.Change_commit_pushed ->
+ Js.Dict.set json "change_commitPushed" Js.Json.null
+ | ChangeTypes.Change_merged ->
+ Js.Dict.set json "change_merged" Js.Json.null
+ end;
+ json
+
+and encode_change_event_optional_duration (v:ChangeTypes.change_event_optional_duration) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | ChangeTypes.Duration v ->
+ Js.Dict.set json "duration" (Js.Json.number (Int32.to_float v));
+ end;
+ json
+
+and encode_change_event_optional_merged_commit_sha (v:ChangeTypes.change_event_optional_merged_commit_sha) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | ChangeTypes.Merged_commit_sha v ->
+ Js.Dict.set json "merged_commitSha" (Js.Json.string v);
+ end;
+ json
+
+and encode_change_event (v:ChangeTypes.change_event) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "id" (Js.Json.string v.ChangeTypes.id);
+ begin match v.ChangeTypes.created_at with
+ | None -> ()
+ | Some v ->
+ begin (* created_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "created_at" (Js.Json.string json');
+ end;
+ end;
+ begin match v.ChangeTypes.author with
+ | None -> ()
+ | Some v ->
+ begin (* author field *)
+ let json' = encode_ident v in
+ Js.Dict.set json "author" (Js.Json.object_ json');
+ end;
+ end;
+ Js.Dict.set json "repository_prefix" (Js.Json.string v.ChangeTypes.repository_prefix);
+ Js.Dict.set json "repository_fullname" (Js.Json.string v.ChangeTypes.repository_fullname);
+ Js.Dict.set json "repository_shortname" (Js.Json.string v.ChangeTypes.repository_shortname);
+ Js.Dict.set json "branch" (Js.Json.string v.ChangeTypes.branch);
+ Js.Dict.set json "target_branch" (Js.Json.string v.ChangeTypes.target_branch);
+ Js.Dict.set json "number" (Js.Json.number (Int32.to_float v.ChangeTypes.number));
+ Js.Dict.set json "change_id" (Js.Json.string v.ChangeTypes.change_id);
+ Js.Dict.set json "url" (Js.Json.string v.ChangeTypes.url);
+ begin match v.ChangeTypes.on_author with
+ | None -> ()
+ | Some v ->
+ begin (* onAuthor field *)
+ let json' = encode_ident v in
+ Js.Dict.set json "on_author" (Js.Json.object_ json');
+ end;
+ end;
+ begin match v.ChangeTypes.on_created_at with
+ | None -> ()
+ | Some v ->
+ begin (* onCreated_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "on_created_at" (Js.Json.string json');
+ end;
+ end;
+ begin (* changedFiles field *)
+ let (changed_files':Js.Json.t) =
+ v.ChangeTypes.changed_files
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> encode_changed_file_path |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "changed_files" changed_files';
+ end;
+ begin match v.ChangeTypes.type_ with
+ | Change_created ->
+ Js.Dict.set json "change_created" Js.Json.null
+ | Change_commented ->
+ Js.Dict.set json "change_commented" Js.Json.null
+ | Change_abandoned ->
+ Js.Dict.set json "change_abandoned" Js.Json.null
+ | Change_reviewed v ->
+ begin (* changeReviewed field *)
+ let json' = encode_change_reviewed_event v in
+ Js.Dict.set json "change_reviewed" (Js.Json.object_ json');
+ end;
+ | Change_commit_force_pushed ->
+ Js.Dict.set json "change_commitForcePushed" Js.Json.null
+ | Change_commit_pushed ->
+ Js.Dict.set json "change_commitPushed" Js.Json.null
+ | Change_merged ->
+ Js.Dict.set json "change_merged" Js.Json.null
+ end; (* match v.type_ *)
+ let a = v.ChangeTypes.labels |> Array.of_list |> Array.map Js.Json.string in
+ Js.Dict.set json "labels" (Js.Json.array a);
+ begin match v.ChangeTypes.optional_duration with
+ | Duration v ->
+ Js.Dict.set json "duration" (Js.Json.number (Int32.to_float v));
+ end; (* match v.optional_duration *)
+ Js.Dict.set json "draft" (Js.Json.boolean v.ChangeTypes.draft);
+ begin match v.ChangeTypes.optional_merged_commit_sha with
+ | Merged_commit_sha v ->
+ Js.Dict.set json "merged_commitSha" (Js.Json.string v);
+ end; (* match v.optional_merged_commit_sha *)
+ json
diff --git a/web/src/messages/ChangeBs.mli b/web/src/messages/ChangeBs.mli
new file mode 100644
index 000000000..d03646441
--- /dev/null
+++ b/web/src/messages/ChangeBs.mli
@@ -0,0 +1,109 @@
+(** change.proto BuckleScript Encoding *)
+
+
+(** {2 Protobuf JSON Encoding} *)
+
+val encode_ident : ChangeTypes.ident -> Js.Json.t Js.Dict.t
+(** [encode_ident v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_changed_file : ChangeTypes.changed_file -> Js.Json.t Js.Dict.t
+(** [encode_changed_file v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_changed_file_path : ChangeTypes.changed_file_path -> Js.Json.t Js.Dict.t
+(** [encode_changed_file_path v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_commit : ChangeTypes.commit -> Js.Json.t Js.Dict.t
+(** [encode_commit v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_change_change_state : ChangeTypes.change_change_state -> string
+(** [encode_change_change_state v] returns JSON string*)
+
+val encode_change_optional_merged_by : ChangeTypes.change_optional_merged_by -> Js.Json.t Js.Dict.t
+(** [encode_change_optional_merged_by v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_change_optional_merged_at : ChangeTypes.change_optional_merged_at -> Js.Json.t Js.Dict.t
+(** [encode_change_optional_merged_at v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_change_optional_closed_at : ChangeTypes.change_optional_closed_at -> Js.Json.t Js.Dict.t
+(** [encode_change_optional_closed_at v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_change_optional_duration : ChangeTypes.change_optional_duration -> Js.Json.t Js.Dict.t
+(** [encode_change_optional_duration v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_change_optional_self_merged : ChangeTypes.change_optional_self_merged -> Js.Json.t Js.Dict.t
+(** [encode_change_optional_self_merged v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_change_optional_merged_commit_sha : ChangeTypes.change_optional_merged_commit_sha -> Js.Json.t Js.Dict.t
+(** [encode_change_optional_merged_commit_sha v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_change : ChangeTypes.change -> Js.Json.t Js.Dict.t
+(** [encode_change v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_change_reviewed_event : ChangeTypes.change_reviewed_event -> Js.Json.t Js.Dict.t
+(** [encode_change_reviewed_event v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_change_event_type : ChangeTypes.change_event_type -> Js.Json.t Js.Dict.t
+(** [encode_change_event_type v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_change_event_optional_duration : ChangeTypes.change_event_optional_duration -> Js.Json.t Js.Dict.t
+(** [encode_change_event_optional_duration v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_change_event_optional_merged_commit_sha : ChangeTypes.change_event_optional_merged_commit_sha -> Js.Json.t Js.Dict.t
+(** [encode_change_event_optional_merged_commit_sha v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_change_event : ChangeTypes.change_event -> Js.Json.t Js.Dict.t
+(** [encode_change_event v dict] encodes [v] int the given JSON [dict] *)
+
+
+(** {2 BS Decoding} *)
+
+val decode_ident : Js.Json.t Js.Dict.t -> ChangeTypes.ident
+(** [decode_ident decoder] decodes a [ident] value from [decoder] *)
+
+val decode_changed_file : Js.Json.t Js.Dict.t -> ChangeTypes.changed_file
+(** [decode_changed_file decoder] decodes a [changed_file] value from [decoder] *)
+
+val decode_changed_file_path : Js.Json.t Js.Dict.t -> ChangeTypes.changed_file_path
+(** [decode_changed_file_path decoder] decodes a [changed_file_path] value from [decoder] *)
+
+val decode_commit : Js.Json.t Js.Dict.t -> ChangeTypes.commit
+(** [decode_commit decoder] decodes a [commit] value from [decoder] *)
+
+val decode_change_change_state : Js.Json.t -> ChangeTypes.change_change_state
+(** [decode_change_change_state value] decodes a [change_change_state] from a Json value*)
+
+val decode_change_optional_merged_by : Js.Json.t Js.Dict.t -> ChangeTypes.change_optional_merged_by
+(** [decode_change_optional_merged_by decoder] decodes a [change_optional_merged_by] value from [decoder] *)
+
+val decode_change_optional_merged_at : Js.Json.t Js.Dict.t -> ChangeTypes.change_optional_merged_at
+(** [decode_change_optional_merged_at decoder] decodes a [change_optional_merged_at] value from [decoder] *)
+
+val decode_change_optional_closed_at : Js.Json.t Js.Dict.t -> ChangeTypes.change_optional_closed_at
+(** [decode_change_optional_closed_at decoder] decodes a [change_optional_closed_at] value from [decoder] *)
+
+val decode_change_optional_duration : Js.Json.t Js.Dict.t -> ChangeTypes.change_optional_duration
+(** [decode_change_optional_duration decoder] decodes a [change_optional_duration] value from [decoder] *)
+
+val decode_change_optional_self_merged : Js.Json.t Js.Dict.t -> ChangeTypes.change_optional_self_merged
+(** [decode_change_optional_self_merged decoder] decodes a [change_optional_self_merged] value from [decoder] *)
+
+val decode_change_optional_merged_commit_sha : Js.Json.t Js.Dict.t -> ChangeTypes.change_optional_merged_commit_sha
+(** [decode_change_optional_merged_commit_sha decoder] decodes a [change_optional_merged_commit_sha] value from [decoder] *)
+
+val decode_change : Js.Json.t Js.Dict.t -> ChangeTypes.change
+(** [decode_change decoder] decodes a [change] value from [decoder] *)
+
+val decode_change_reviewed_event : Js.Json.t Js.Dict.t -> ChangeTypes.change_reviewed_event
+(** [decode_change_reviewed_event decoder] decodes a [change_reviewed_event] value from [decoder] *)
+
+val decode_change_event_type : Js.Json.t Js.Dict.t -> ChangeTypes.change_event_type
+(** [decode_change_event_type decoder] decodes a [change_event_type] value from [decoder] *)
+
+val decode_change_event_optional_duration : Js.Json.t Js.Dict.t -> ChangeTypes.change_event_optional_duration
+(** [decode_change_event_optional_duration decoder] decodes a [change_event_optional_duration] value from [decoder] *)
+
+val decode_change_event_optional_merged_commit_sha : Js.Json.t Js.Dict.t -> ChangeTypes.change_event_optional_merged_commit_sha
+(** [decode_change_event_optional_merged_commit_sha decoder] decodes a [change_event_optional_merged_commit_sha] value from [decoder] *)
+
+val decode_change_event : Js.Json.t Js.Dict.t -> ChangeTypes.change_event
+(** [decode_change_event decoder] decodes a [change_event] value from [decoder] *)
diff --git a/web/src/messages/ChangeTypes.ml b/web/src/messages/ChangeTypes.ml
new file mode 100644
index 000000000..fe10e1467
--- /dev/null
+++ b/web/src/messages/ChangeTypes.ml
@@ -0,0 +1,310 @@
+[@@@ocaml.warning "-27-30-39"]
+
+
+type ident = {
+ uid : string;
+ muid : string;
+ groups : string list;
+}
+
+type changed_file = {
+ additions : int32;
+ deletions : int32;
+ path : string;
+}
+
+type changed_file_path = {
+ path : string;
+}
+
+type commit = {
+ sha : string;
+ author : ident option;
+ committer : ident option;
+ authored_at : TimestampTypes.timestamp option;
+ committed_at : TimestampTypes.timestamp option;
+ additions : int32;
+ deletions : int32;
+ title : string;
+}
+
+type change_change_state =
+ | Open
+ | Merged
+ | Closed
+
+type change_optional_merged_by =
+ | Merged_by of ident
+
+and change_optional_merged_at =
+ | Merged_at of TimestampTypes.timestamp
+
+and change_optional_closed_at =
+ | Closed_at of TimestampTypes.timestamp
+
+and change_optional_duration =
+ | Duration of int32
+
+and change_optional_self_merged =
+ | Self_merged of bool
+
+and change_optional_merged_commit_sha =
+ | Merged_commit_sha of string
+
+and change = {
+ id : string;
+ number : int32;
+ change_id : string;
+ title : string;
+ text : string;
+ url : string;
+ commit_count : int32;
+ additions : int32;
+ deletions : int32;
+ changed_files_count : int32;
+ changed_files : changed_file list;
+ commits : commit list;
+ repository_prefix : string;
+ repository_fullname : string;
+ repository_shortname : string;
+ author : ident option;
+ optional_merged_by : change_optional_merged_by;
+ branch : string;
+ target_branch : string;
+ created_at : TimestampTypes.timestamp option;
+ optional_merged_at : change_optional_merged_at;
+ updated_at : TimestampTypes.timestamp option;
+ optional_closed_at : change_optional_closed_at;
+ state : change_change_state;
+ optional_duration : change_optional_duration;
+ mergeable : string;
+ labels : string list;
+ assignees : ident list;
+ approvals : string list;
+ draft : bool;
+ optional_self_merged : change_optional_self_merged;
+ optional_merged_commit_sha : change_optional_merged_commit_sha;
+}
+
+type change_reviewed_event = {
+ approvals : string list;
+}
+
+type change_event_type =
+ | Change_created
+ | Change_commented
+ | Change_abandoned
+ | Change_reviewed of change_reviewed_event
+ | Change_commit_force_pushed
+ | Change_commit_pushed
+ | Change_merged
+
+and change_event_optional_duration =
+ | Duration of int32
+
+and change_event_optional_merged_commit_sha =
+ | Merged_commit_sha of string
+
+and change_event = {
+ id : string;
+ created_at : TimestampTypes.timestamp option;
+ author : ident option;
+ repository_prefix : string;
+ repository_fullname : string;
+ repository_shortname : string;
+ branch : string;
+ target_branch : string;
+ number : int32;
+ change_id : string;
+ url : string;
+ on_author : ident option;
+ on_created_at : TimestampTypes.timestamp option;
+ changed_files : changed_file_path list;
+ type_ : change_event_type;
+ labels : string list;
+ optional_duration : change_event_optional_duration;
+ draft : bool;
+ optional_merged_commit_sha : change_event_optional_merged_commit_sha;
+}
+
+let rec default_ident
+ ?uid:((uid:string) = "")
+ ?muid:((muid:string) = "")
+ ?groups:((groups:string list) = [])
+ () : ident = {
+ uid;
+ muid;
+ groups;
+}
+
+let rec default_changed_file
+ ?additions:((additions:int32) = 0l)
+ ?deletions:((deletions:int32) = 0l)
+ ?path:((path:string) = "")
+ () : changed_file = {
+ additions;
+ deletions;
+ path;
+}
+
+let rec default_changed_file_path
+ ?path:((path:string) = "")
+ () : changed_file_path = {
+ path;
+}
+
+let rec default_commit
+ ?sha:((sha:string) = "")
+ ?author:((author:ident option) = None)
+ ?committer:((committer:ident option) = None)
+ ?authored_at:((authored_at:TimestampTypes.timestamp option) = None)
+ ?committed_at:((committed_at:TimestampTypes.timestamp option) = None)
+ ?additions:((additions:int32) = 0l)
+ ?deletions:((deletions:int32) = 0l)
+ ?title:((title:string) = "")
+ () : commit = {
+ sha;
+ author;
+ committer;
+ authored_at;
+ committed_at;
+ additions;
+ deletions;
+ title;
+}
+
+let rec default_change_change_state () = (Open:change_change_state)
+
+let rec default_change_optional_merged_by () : change_optional_merged_by = Merged_by (default_ident ())
+
+and default_change_optional_merged_at () : change_optional_merged_at = Merged_at (TimestampTypes.default_timestamp)
+
+and default_change_optional_closed_at () : change_optional_closed_at = Closed_at (TimestampTypes.default_timestamp)
+
+and default_change_optional_duration () : change_optional_duration = Duration (0l)
+
+and default_change_optional_self_merged () : change_optional_self_merged = Self_merged (false)
+
+and default_change_optional_merged_commit_sha () : change_optional_merged_commit_sha = Merged_commit_sha ("")
+
+and default_change
+ ?id:((id:string) = "")
+ ?number:((number:int32) = 0l)
+ ?change_id:((change_id:string) = "")
+ ?title:((title:string) = "")
+ ?text:((text:string) = "")
+ ?url:((url:string) = "")
+ ?commit_count:((commit_count:int32) = 0l)
+ ?additions:((additions:int32) = 0l)
+ ?deletions:((deletions:int32) = 0l)
+ ?changed_files_count:((changed_files_count:int32) = 0l)
+ ?changed_files:((changed_files:changed_file list) = [])
+ ?commits:((commits:commit list) = [])
+ ?repository_prefix:((repository_prefix:string) = "")
+ ?repository_fullname:((repository_fullname:string) = "")
+ ?repository_shortname:((repository_shortname:string) = "")
+ ?author:((author:ident option) = None)
+ ?optional_merged_by:((optional_merged_by:change_optional_merged_by) = Merged_by (default_ident ()))
+ ?branch:((branch:string) = "")
+ ?target_branch:((target_branch:string) = "")
+ ?created_at:((created_at:TimestampTypes.timestamp option) = None)
+ ?optional_merged_at:((optional_merged_at:change_optional_merged_at) = Merged_at (TimestampTypes.default_timestamp))
+ ?updated_at:((updated_at:TimestampTypes.timestamp option) = None)
+ ?optional_closed_at:((optional_closed_at:change_optional_closed_at) = Closed_at (TimestampTypes.default_timestamp))
+ ?state:((state:change_change_state) = default_change_change_state ())
+ ?optional_duration:((optional_duration:change_optional_duration) = Duration (0l))
+ ?mergeable:((mergeable:string) = "")
+ ?labels:((labels:string list) = [])
+ ?assignees:((assignees:ident list) = [])
+ ?approvals:((approvals:string list) = [])
+ ?draft:((draft:bool) = false)
+ ?optional_self_merged:((optional_self_merged:change_optional_self_merged) = Self_merged (false))
+ ?optional_merged_commit_sha:((optional_merged_commit_sha:change_optional_merged_commit_sha) = Merged_commit_sha (""))
+ () : change = {
+ id;
+ number;
+ change_id;
+ title;
+ text;
+ url;
+ commit_count;
+ additions;
+ deletions;
+ changed_files_count;
+ changed_files;
+ commits;
+ repository_prefix;
+ repository_fullname;
+ repository_shortname;
+ author;
+ optional_merged_by;
+ branch;
+ target_branch;
+ created_at;
+ optional_merged_at;
+ updated_at;
+ optional_closed_at;
+ state;
+ optional_duration;
+ mergeable;
+ labels;
+ assignees;
+ approvals;
+ draft;
+ optional_self_merged;
+ optional_merged_commit_sha;
+}
+
+let rec default_change_reviewed_event
+ ?approvals:((approvals:string list) = [])
+ () : change_reviewed_event = {
+ approvals;
+}
+
+let rec default_change_event_type (): change_event_type = Change_created
+
+and default_change_event_optional_duration () : change_event_optional_duration = Duration (0l)
+
+and default_change_event_optional_merged_commit_sha () : change_event_optional_merged_commit_sha = Merged_commit_sha ("")
+
+and default_change_event
+ ?id:((id:string) = "")
+ ?created_at:((created_at:TimestampTypes.timestamp option) = None)
+ ?author:((author:ident option) = None)
+ ?repository_prefix:((repository_prefix:string) = "")
+ ?repository_fullname:((repository_fullname:string) = "")
+ ?repository_shortname:((repository_shortname:string) = "")
+ ?branch:((branch:string) = "")
+ ?target_branch:((target_branch:string) = "")
+ ?number:((number:int32) = 0l)
+ ?change_id:((change_id:string) = "")
+ ?url:((url:string) = "")
+ ?on_author:((on_author:ident option) = None)
+ ?on_created_at:((on_created_at:TimestampTypes.timestamp option) = None)
+ ?changed_files:((changed_files:changed_file_path list) = [])
+ ?type_:((type_:change_event_type) = Change_created)
+ ?labels:((labels:string list) = [])
+ ?optional_duration:((optional_duration:change_event_optional_duration) = Duration (0l))
+ ?draft:((draft:bool) = false)
+ ?optional_merged_commit_sha:((optional_merged_commit_sha:change_event_optional_merged_commit_sha) = Merged_commit_sha (""))
+ () : change_event = {
+ id;
+ created_at;
+ author;
+ repository_prefix;
+ repository_fullname;
+ repository_shortname;
+ branch;
+ target_branch;
+ number;
+ change_id;
+ url;
+ on_author;
+ on_created_at;
+ changed_files;
+ type_;
+ labels;
+ optional_duration;
+ draft;
+ optional_merged_commit_sha;
+}
diff --git a/web/src/messages/ChangeTypes.mli b/web/src/messages/ChangeTypes.mli
new file mode 100644
index 000000000..578239a4c
--- /dev/null
+++ b/web/src/messages/ChangeTypes.mli
@@ -0,0 +1,266 @@
+(** change.proto Types *)
+
+
+
+(** {2 Types} *)
+
+type ident = {
+ uid : string;
+ muid : string;
+ groups : string list;
+}
+
+type changed_file = {
+ additions : int32;
+ deletions : int32;
+ path : string;
+}
+
+type changed_file_path = {
+ path : string;
+}
+
+type commit = {
+ sha : string;
+ author : ident option;
+ committer : ident option;
+ authored_at : TimestampTypes.timestamp option;
+ committed_at : TimestampTypes.timestamp option;
+ additions : int32;
+ deletions : int32;
+ title : string;
+}
+
+type change_change_state =
+ | Open
+ | Merged
+ | Closed
+
+type change_optional_merged_by =
+ | Merged_by of ident
+
+and change_optional_merged_at =
+ | Merged_at of TimestampTypes.timestamp
+
+and change_optional_closed_at =
+ | Closed_at of TimestampTypes.timestamp
+
+and change_optional_duration =
+ | Duration of int32
+
+and change_optional_self_merged =
+ | Self_merged of bool
+
+and change_optional_merged_commit_sha =
+ | Merged_commit_sha of string
+
+and change = {
+ id : string;
+ number : int32;
+ change_id : string;
+ title : string;
+ text : string;
+ url : string;
+ commit_count : int32;
+ additions : int32;
+ deletions : int32;
+ changed_files_count : int32;
+ changed_files : changed_file list;
+ commits : commit list;
+ repository_prefix : string;
+ repository_fullname : string;
+ repository_shortname : string;
+ author : ident option;
+ optional_merged_by : change_optional_merged_by;
+ branch : string;
+ target_branch : string;
+ created_at : TimestampTypes.timestamp option;
+ optional_merged_at : change_optional_merged_at;
+ updated_at : TimestampTypes.timestamp option;
+ optional_closed_at : change_optional_closed_at;
+ state : change_change_state;
+ optional_duration : change_optional_duration;
+ mergeable : string;
+ labels : string list;
+ assignees : ident list;
+ approvals : string list;
+ draft : bool;
+ optional_self_merged : change_optional_self_merged;
+ optional_merged_commit_sha : change_optional_merged_commit_sha;
+}
+
+type change_reviewed_event = {
+ approvals : string list;
+}
+
+type change_event_type =
+ | Change_created
+ | Change_commented
+ | Change_abandoned
+ | Change_reviewed of change_reviewed_event
+ | Change_commit_force_pushed
+ | Change_commit_pushed
+ | Change_merged
+
+and change_event_optional_duration =
+ | Duration of int32
+
+and change_event_optional_merged_commit_sha =
+ | Merged_commit_sha of string
+
+and change_event = {
+ id : string;
+ created_at : TimestampTypes.timestamp option;
+ author : ident option;
+ repository_prefix : string;
+ repository_fullname : string;
+ repository_shortname : string;
+ branch : string;
+ target_branch : string;
+ number : int32;
+ change_id : string;
+ url : string;
+ on_author : ident option;
+ on_created_at : TimestampTypes.timestamp option;
+ changed_files : changed_file_path list;
+ type_ : change_event_type;
+ labels : string list;
+ optional_duration : change_event_optional_duration;
+ draft : bool;
+ optional_merged_commit_sha : change_event_optional_merged_commit_sha;
+}
+
+
+(** {2 Default values} *)
+
+val default_ident :
+ ?uid:string ->
+ ?muid:string ->
+ ?groups:string list ->
+ unit ->
+ ident
+(** [default_ident ()] is the default value for type [ident] *)
+
+val default_changed_file :
+ ?additions:int32 ->
+ ?deletions:int32 ->
+ ?path:string ->
+ unit ->
+ changed_file
+(** [default_changed_file ()] is the default value for type [changed_file] *)
+
+val default_changed_file_path :
+ ?path:string ->
+ unit ->
+ changed_file_path
+(** [default_changed_file_path ()] is the default value for type [changed_file_path] *)
+
+val default_commit :
+ ?sha:string ->
+ ?author:ident option ->
+ ?committer:ident option ->
+ ?authored_at:TimestampTypes.timestamp option ->
+ ?committed_at:TimestampTypes.timestamp option ->
+ ?additions:int32 ->
+ ?deletions:int32 ->
+ ?title:string ->
+ unit ->
+ commit
+(** [default_commit ()] is the default value for type [commit] *)
+
+val default_change_change_state : unit -> change_change_state
+(** [default_change_change_state ()] is the default value for type [change_change_state] *)
+
+val default_change_optional_merged_by : unit -> change_optional_merged_by
+(** [default_change_optional_merged_by ()] is the default value for type [change_optional_merged_by] *)
+
+val default_change_optional_merged_at : unit -> change_optional_merged_at
+(** [default_change_optional_merged_at ()] is the default value for type [change_optional_merged_at] *)
+
+val default_change_optional_closed_at : unit -> change_optional_closed_at
+(** [default_change_optional_closed_at ()] is the default value for type [change_optional_closed_at] *)
+
+val default_change_optional_duration : unit -> change_optional_duration
+(** [default_change_optional_duration ()] is the default value for type [change_optional_duration] *)
+
+val default_change_optional_self_merged : unit -> change_optional_self_merged
+(** [default_change_optional_self_merged ()] is the default value for type [change_optional_self_merged] *)
+
+val default_change_optional_merged_commit_sha : unit -> change_optional_merged_commit_sha
+(** [default_change_optional_merged_commit_sha ()] is the default value for type [change_optional_merged_commit_sha] *)
+
+val default_change :
+ ?id:string ->
+ ?number:int32 ->
+ ?change_id:string ->
+ ?title:string ->
+ ?text:string ->
+ ?url:string ->
+ ?commit_count:int32 ->
+ ?additions:int32 ->
+ ?deletions:int32 ->
+ ?changed_files_count:int32 ->
+ ?changed_files:changed_file list ->
+ ?commits:commit list ->
+ ?repository_prefix:string ->
+ ?repository_fullname:string ->
+ ?repository_shortname:string ->
+ ?author:ident option ->
+ ?optional_merged_by:change_optional_merged_by ->
+ ?branch:string ->
+ ?target_branch:string ->
+ ?created_at:TimestampTypes.timestamp option ->
+ ?optional_merged_at:change_optional_merged_at ->
+ ?updated_at:TimestampTypes.timestamp option ->
+ ?optional_closed_at:change_optional_closed_at ->
+ ?state:change_change_state ->
+ ?optional_duration:change_optional_duration ->
+ ?mergeable:string ->
+ ?labels:string list ->
+ ?assignees:ident list ->
+ ?approvals:string list ->
+ ?draft:bool ->
+ ?optional_self_merged:change_optional_self_merged ->
+ ?optional_merged_commit_sha:change_optional_merged_commit_sha ->
+ unit ->
+ change
+(** [default_change ()] is the default value for type [change] *)
+
+val default_change_reviewed_event :
+ ?approvals:string list ->
+ unit ->
+ change_reviewed_event
+(** [default_change_reviewed_event ()] is the default value for type [change_reviewed_event] *)
+
+val default_change_event_type : unit -> change_event_type
+(** [default_change_event_type ()] is the default value for type [change_event_type] *)
+
+val default_change_event_optional_duration : unit -> change_event_optional_duration
+(** [default_change_event_optional_duration ()] is the default value for type [change_event_optional_duration] *)
+
+val default_change_event_optional_merged_commit_sha : unit -> change_event_optional_merged_commit_sha
+(** [default_change_event_optional_merged_commit_sha ()] is the default value for type [change_event_optional_merged_commit_sha] *)
+
+val default_change_event :
+ ?id:string ->
+ ?created_at:TimestampTypes.timestamp option ->
+ ?author:ident option ->
+ ?repository_prefix:string ->
+ ?repository_fullname:string ->
+ ?repository_shortname:string ->
+ ?branch:string ->
+ ?target_branch:string ->
+ ?number:int32 ->
+ ?change_id:string ->
+ ?url:string ->
+ ?on_author:ident option ->
+ ?on_created_at:TimestampTypes.timestamp option ->
+ ?changed_files:changed_file_path list ->
+ ?type_:change_event_type ->
+ ?labels:string list ->
+ ?optional_duration:change_event_optional_duration ->
+ ?draft:bool ->
+ ?optional_merged_commit_sha:change_event_optional_merged_commit_sha ->
+ unit ->
+ change_event
+(** [default_change_event ()] is the default value for type [change_event] *)
diff --git a/web/src/messages/CrawlerBs.ml b/web/src/messages/CrawlerBs.ml
new file mode 100644
index 000000000..2029af094
--- /dev/null
+++ b/web/src/messages/CrawlerBs.ml
@@ -0,0 +1,840 @@
+[@@@ocaml.warning "-27-30-39"]
+
+type crawler_error_mutable = {
+ mutable message : string;
+ mutable body : string;
+ mutable created_at : TimestampTypes.timestamp option;
+}
+
+let default_crawler_error_mutable () : crawler_error_mutable = {
+ message = "";
+ body = "";
+ created_at = None;
+}
+
+type crawler_error_list_mutable = {
+ mutable crawler : string;
+ mutable entity : CrawlerTypes.entity option;
+ mutable errors : CrawlerTypes.crawler_error list;
+}
+
+let default_crawler_error_list_mutable () : crawler_error_list_mutable = {
+ crawler = "";
+ entity = None;
+ errors = [];
+}
+
+type errors_request_mutable = {
+ mutable index : string;
+ mutable query : string;
+}
+
+let default_errors_request_mutable () : errors_request_mutable = {
+ index = "";
+ query = "";
+}
+
+type errors_list_mutable = {
+ mutable errors : CrawlerTypes.crawler_error_list list;
+}
+
+let default_errors_list_mutable () : errors_list_mutable = {
+ errors = [];
+}
+
+type project_mutable = {
+ mutable full_path : string;
+}
+
+let default_project_mutable () : project_mutable = {
+ full_path = "";
+}
+
+type add_doc_request_mutable = {
+ mutable index : string;
+ mutable crawler : string;
+ mutable apikey : string;
+ mutable entity : CrawlerTypes.entity option;
+ mutable changes : ChangeTypes.change list;
+ mutable events : ChangeTypes.change_event list;
+ mutable projects : CrawlerTypes.project list;
+ mutable task_datas : SearchTypes.task_data list;
+ mutable issues : IssueTypes.issue list;
+ mutable issue_events : IssueTypes.issue_event list;
+ mutable errors : CrawlerTypes.crawler_error list;
+}
+
+let default_add_doc_request_mutable () : add_doc_request_mutable = {
+ index = "";
+ crawler = "";
+ apikey = "";
+ entity = None;
+ changes = [];
+ events = [];
+ projects = [];
+ task_datas = [];
+ issues = [];
+ issue_events = [];
+ errors = [];
+}
+
+type commit_request_mutable = {
+ mutable index : string;
+ mutable crawler : string;
+ mutable apikey : string;
+ mutable entity : CrawlerTypes.entity option;
+ mutable timestamp : TimestampTypes.timestamp option;
+}
+
+let default_commit_request_mutable () : commit_request_mutable = {
+ index = "";
+ crawler = "";
+ apikey = "";
+ entity = None;
+ timestamp = None;
+}
+
+type commit_info_request_mutable = {
+ mutable index : string;
+ mutable crawler : string;
+ mutable entity : CrawlerTypes.entity_type;
+ mutable offset : int32;
+}
+
+let default_commit_info_request_mutable () : commit_info_request_mutable = {
+ index = "";
+ crawler = "";
+ entity = CrawlerTypes.default_entity_type ();
+ offset = 0l;
+}
+
+type commit_info_response_oldest_entity_mutable = {
+ mutable entity : CrawlerTypes.entity option;
+ mutable last_commit_at : TimestampTypes.timestamp option;
+}
+
+let default_commit_info_response_oldest_entity_mutable () : commit_info_response_oldest_entity_mutable = {
+ entity = None;
+ last_commit_at = None;
+}
+
+
+let rec decode_entity json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "entity"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "organization_name" ->
+ let json = Js.Dict.unsafeGet json "organization_name" in
+ (CrawlerTypes.Organization_name (Pbrt_bs.string json "entity" "Organization_name") : CrawlerTypes.entity)
+ | "project_name" ->
+ let json = Js.Dict.unsafeGet json "project_name" in
+ (CrawlerTypes.Project_name (Pbrt_bs.string json "entity" "Project_name") : CrawlerTypes.entity)
+ | "project_issueName" ->
+ let json = Js.Dict.unsafeGet json "project_issueName" in
+ (CrawlerTypes.Project_issue_name (Pbrt_bs.string json "entity" "Project_issue_name") : CrawlerTypes.entity)
+ | "td_name" ->
+ let json = Js.Dict.unsafeGet json "td_name" in
+ (CrawlerTypes.Td_name (Pbrt_bs.string json "entity" "Td_name") : CrawlerTypes.entity)
+ | "user_name" ->
+ let json = Js.Dict.unsafeGet json "user_name" in
+ (CrawlerTypes.User_name (Pbrt_bs.string json "entity" "User_name") : CrawlerTypes.entity)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+let rec decode_entity_type (json:Js.Json.t) =
+ match Pbrt_bs.string json "entity_type" "value" with
+ | "ENTITY_TYPE_ORGANIZATION" -> (CrawlerTypes.Entity_type_organization : CrawlerTypes.entity_type)
+ | "ENTITY_TYPE_PROJECT" -> (CrawlerTypes.Entity_type_project : CrawlerTypes.entity_type)
+ | "ENTITY_TYPE_TASK_DATA" -> (CrawlerTypes.Entity_type_task_data : CrawlerTypes.entity_type)
+ | "ENTITY_TYPE_USER" -> (CrawlerTypes.Entity_type_user : CrawlerTypes.entity_type)
+ | "" -> CrawlerTypes.Entity_type_organization
+ | _ -> Pbrt_bs.E.malformed_variant "entity_type"
+
+let rec decode_crawler_error json =
+ let v = default_crawler_error_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "message" ->
+ let json = Js.Dict.unsafeGet json "message" in
+ v.message <- Pbrt_bs.string json "crawler_error" "message"
+ | "body" ->
+ let json = Js.Dict.unsafeGet json "body" in
+ v.body <- Pbrt_bs.string json "crawler_error" "body"
+ | "created_at" ->
+ let json = Js.Dict.unsafeGet json "created_at" in
+ v.created_at <- Some ((TimestampBs.decode_timestamp (Pbrt_bs.string json "crawler_error" "created_at")))
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ CrawlerTypes.message = v.message;
+ CrawlerTypes.body = v.body;
+ CrawlerTypes.created_at = v.created_at;
+ } : CrawlerTypes.crawler_error)
+
+let rec decode_crawler_error_list json =
+ let v = default_crawler_error_list_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "crawler" ->
+ let json = Js.Dict.unsafeGet json "crawler" in
+ v.crawler <- Pbrt_bs.string json "crawler_error_list" "crawler"
+ | "entity" ->
+ let json = Js.Dict.unsafeGet json "entity" in
+ v.entity <- Some ((decode_entity (Pbrt_bs.object_ json "crawler_error_list" "entity")))
+ | "errors" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "errors" in
+ Pbrt_bs.array_ a "crawler_error_list" "errors"
+ in
+ v.errors <- Array.map (fun json ->
+ (decode_crawler_error (Pbrt_bs.object_ json "crawler_error_list" "errors"))
+ ) a |> Array.to_list;
+ end
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ CrawlerTypes.crawler = v.crawler;
+ CrawlerTypes.entity = v.entity;
+ CrawlerTypes.errors = v.errors;
+ } : CrawlerTypes.crawler_error_list)
+
+let rec decode_errors_request json =
+ let v = default_errors_request_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "index" ->
+ let json = Js.Dict.unsafeGet json "index" in
+ v.index <- Pbrt_bs.string json "errors_request" "index"
+ | "query" ->
+ let json = Js.Dict.unsafeGet json "query" in
+ v.query <- Pbrt_bs.string json "errors_request" "query"
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ CrawlerTypes.index = v.index;
+ CrawlerTypes.query = v.query;
+ } : CrawlerTypes.errors_request)
+
+let rec decode_errors_list json =
+ let v = default_errors_list_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "errors" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "errors" in
+ Pbrt_bs.array_ a "errors_list" "errors"
+ in
+ v.errors <- Array.map (fun json ->
+ (decode_crawler_error_list (Pbrt_bs.object_ json "errors_list" "errors"))
+ ) a |> Array.to_list;
+ end
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ CrawlerTypes.errors = v.errors;
+ } : CrawlerTypes.errors_list)
+
+let rec decode_errors_response json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "errors_response"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "success" ->
+ let json = Js.Dict.unsafeGet json "success" in
+ (CrawlerTypes.Success ((decode_errors_list (Pbrt_bs.object_ json "errors_response" "Success"))) : CrawlerTypes.errors_response)
+ | "error" ->
+ let json = Js.Dict.unsafeGet json "error" in
+ (CrawlerTypes.Error (Pbrt_bs.string json "errors_response" "Error") : CrawlerTypes.errors_response)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+let rec decode_project json =
+ let v = default_project_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "full_path" ->
+ let json = Js.Dict.unsafeGet json "full_path" in
+ v.full_path <- Pbrt_bs.string json "project" "full_path"
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ CrawlerTypes.full_path = v.full_path;
+ } : CrawlerTypes.project)
+
+let rec decode_add_doc_request json =
+ let v = default_add_doc_request_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "index" ->
+ let json = Js.Dict.unsafeGet json "index" in
+ v.index <- Pbrt_bs.string json "add_doc_request" "index"
+ | "crawler" ->
+ let json = Js.Dict.unsafeGet json "crawler" in
+ v.crawler <- Pbrt_bs.string json "add_doc_request" "crawler"
+ | "apikey" ->
+ let json = Js.Dict.unsafeGet json "apikey" in
+ v.apikey <- Pbrt_bs.string json "add_doc_request" "apikey"
+ | "entity" ->
+ let json = Js.Dict.unsafeGet json "entity" in
+ v.entity <- Some ((decode_entity (Pbrt_bs.object_ json "add_doc_request" "entity")))
+ | "changes" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "changes" in
+ Pbrt_bs.array_ a "add_doc_request" "changes"
+ in
+ v.changes <- Array.map (fun json ->
+ (ChangeBs.decode_change (Pbrt_bs.object_ json "add_doc_request" "changes"))
+ ) a |> Array.to_list;
+ end
+ | "events" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "events" in
+ Pbrt_bs.array_ a "add_doc_request" "events"
+ in
+ v.events <- Array.map (fun json ->
+ (ChangeBs.decode_change_event (Pbrt_bs.object_ json "add_doc_request" "events"))
+ ) a |> Array.to_list;
+ end
+ | "projects" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "projects" in
+ Pbrt_bs.array_ a "add_doc_request" "projects"
+ in
+ v.projects <- Array.map (fun json ->
+ (decode_project (Pbrt_bs.object_ json "add_doc_request" "projects"))
+ ) a |> Array.to_list;
+ end
+ | "task_datas" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "task_datas" in
+ Pbrt_bs.array_ a "add_doc_request" "task_datas"
+ in
+ v.task_datas <- Array.map (fun json ->
+ (SearchBs.decode_task_data (Pbrt_bs.object_ json "add_doc_request" "task_datas"))
+ ) a |> Array.to_list;
+ end
+ | "issues" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "issues" in
+ Pbrt_bs.array_ a "add_doc_request" "issues"
+ in
+ v.issues <- Array.map (fun json ->
+ (IssueBs.decode_issue (Pbrt_bs.object_ json "add_doc_request" "issues"))
+ ) a |> Array.to_list;
+ end
+ | "issue_events" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "issue_events" in
+ Pbrt_bs.array_ a "add_doc_request" "issue_events"
+ in
+ v.issue_events <- Array.map (fun json ->
+ (IssueBs.decode_issue_event (Pbrt_bs.object_ json "add_doc_request" "issue_events"))
+ ) a |> Array.to_list;
+ end
+ | "errors" -> begin
+ let a =
+ let a = Js.Dict.unsafeGet json "errors" in
+ Pbrt_bs.array_ a "add_doc_request" "errors"
+ in
+ v.errors <- Array.map (fun json ->
+ (decode_crawler_error (Pbrt_bs.object_ json "add_doc_request" "errors"))
+ ) a |> Array.to_list;
+ end
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ CrawlerTypes.index = v.index;
+ CrawlerTypes.crawler = v.crawler;
+ CrawlerTypes.apikey = v.apikey;
+ CrawlerTypes.entity = v.entity;
+ CrawlerTypes.changes = v.changes;
+ CrawlerTypes.events = v.events;
+ CrawlerTypes.projects = v.projects;
+ CrawlerTypes.task_datas = v.task_datas;
+ CrawlerTypes.issues = v.issues;
+ CrawlerTypes.issue_events = v.issue_events;
+ CrawlerTypes.errors = v.errors;
+ } : CrawlerTypes.add_doc_request)
+
+let rec decode_add_doc_error (json:Js.Json.t) =
+ match Pbrt_bs.string json "add_doc_error" "value" with
+ | "AddUnknownIndex" -> (CrawlerTypes.Add_unknown_index : CrawlerTypes.add_doc_error)
+ | "AddUnknownCrawler" -> (CrawlerTypes.Add_unknown_crawler : CrawlerTypes.add_doc_error)
+ | "AddUnknownApiKey" -> (CrawlerTypes.Add_unknown_api_key : CrawlerTypes.add_doc_error)
+ | "AddFailed" -> (CrawlerTypes.Add_failed : CrawlerTypes.add_doc_error)
+ | "" -> CrawlerTypes.Add_unknown_index
+ | _ -> Pbrt_bs.E.malformed_variant "add_doc_error"
+
+let rec decode_add_doc_response json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "add_doc_response"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "error" ->
+ let json = Js.Dict.unsafeGet json "error" in
+ (CrawlerTypes.Error ((decode_add_doc_error json)) : CrawlerTypes.add_doc_response)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+let rec decode_commit_request json =
+ let v = default_commit_request_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "index" ->
+ let json = Js.Dict.unsafeGet json "index" in
+ v.index <- Pbrt_bs.string json "commit_request" "index"
+ | "crawler" ->
+ let json = Js.Dict.unsafeGet json "crawler" in
+ v.crawler <- Pbrt_bs.string json "commit_request" "crawler"
+ | "apikey" ->
+ let json = Js.Dict.unsafeGet json "apikey" in
+ v.apikey <- Pbrt_bs.string json "commit_request" "apikey"
+ | "entity" ->
+ let json = Js.Dict.unsafeGet json "entity" in
+ v.entity <- Some ((decode_entity (Pbrt_bs.object_ json "commit_request" "entity")))
+ | "timestamp" ->
+ let json = Js.Dict.unsafeGet json "timestamp" in
+ v.timestamp <- Some ((TimestampBs.decode_timestamp (Pbrt_bs.string json "commit_request" "timestamp")))
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ CrawlerTypes.index = v.index;
+ CrawlerTypes.crawler = v.crawler;
+ CrawlerTypes.apikey = v.apikey;
+ CrawlerTypes.entity = v.entity;
+ CrawlerTypes.timestamp = v.timestamp;
+ } : CrawlerTypes.commit_request)
+
+let rec decode_commit_error (json:Js.Json.t) =
+ match Pbrt_bs.string json "commit_error" "value" with
+ | "CommitUnknownIndex" -> (CrawlerTypes.Commit_unknown_index : CrawlerTypes.commit_error)
+ | "CommitUnknownCrawler" -> (CrawlerTypes.Commit_unknown_crawler : CrawlerTypes.commit_error)
+ | "CommitUnknownApiKey" -> (CrawlerTypes.Commit_unknown_api_key : CrawlerTypes.commit_error)
+ | "CommitDateInferiorThanPrevious" -> (CrawlerTypes.Commit_date_inferior_than_previous : CrawlerTypes.commit_error)
+ | "CommitDateMissing" -> (CrawlerTypes.Commit_date_missing : CrawlerTypes.commit_error)
+ | "" -> CrawlerTypes.Commit_unknown_index
+ | _ -> Pbrt_bs.E.malformed_variant "commit_error"
+
+let rec decode_commit_response json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "commit_response"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "error" ->
+ let json = Js.Dict.unsafeGet json "error" in
+ (CrawlerTypes.Error ((decode_commit_error json)) : CrawlerTypes.commit_response)
+ | "timestamp" ->
+ let json = Js.Dict.unsafeGet json "timestamp" in
+ (CrawlerTypes.Timestamp ((TimestampBs.decode_timestamp (Pbrt_bs.string json "commit_response" "Timestamp"))) : CrawlerTypes.commit_response)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+let rec decode_commit_info_request json =
+ let v = default_commit_info_request_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "index" ->
+ let json = Js.Dict.unsafeGet json "index" in
+ v.index <- Pbrt_bs.string json "commit_info_request" "index"
+ | "crawler" ->
+ let json = Js.Dict.unsafeGet json "crawler" in
+ v.crawler <- Pbrt_bs.string json "commit_info_request" "crawler"
+ | "entity" ->
+ let json = Js.Dict.unsafeGet json "entity" in
+ v.entity <- (decode_entity_type json)
+ | "offset" ->
+ let json = Js.Dict.unsafeGet json "offset" in
+ v.offset <- Pbrt_bs.int32 json "commit_info_request" "offset"
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ CrawlerTypes.index = v.index;
+ CrawlerTypes.crawler = v.crawler;
+ CrawlerTypes.entity = v.entity;
+ CrawlerTypes.offset = v.offset;
+ } : CrawlerTypes.commit_info_request)
+
+let rec decode_commit_info_error (json:Js.Json.t) =
+ match Pbrt_bs.string json "commit_info_error" "value" with
+ | "CommitGetUnknownIndex" -> (CrawlerTypes.Commit_get_unknown_index : CrawlerTypes.commit_info_error)
+ | "CommitGetUnknownCrawler" -> (CrawlerTypes.Commit_get_unknown_crawler : CrawlerTypes.commit_info_error)
+ | "CommitGetNoEntity" -> (CrawlerTypes.Commit_get_no_entity : CrawlerTypes.commit_info_error)
+ | "" -> CrawlerTypes.Commit_get_unknown_index
+ | _ -> Pbrt_bs.E.malformed_variant "commit_info_error"
+
+let rec decode_commit_info_response_oldest_entity json =
+ let v = default_commit_info_response_oldest_entity_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "entity" ->
+ let json = Js.Dict.unsafeGet json "entity" in
+ v.entity <- Some ((decode_entity (Pbrt_bs.object_ json "commit_info_response_oldest_entity" "entity")))
+ | "last_commit_at" ->
+ let json = Js.Dict.unsafeGet json "last_commit_at" in
+ v.last_commit_at <- Some ((TimestampBs.decode_timestamp (Pbrt_bs.string json "commit_info_response_oldest_entity" "last_commit_at")))
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ CrawlerTypes.entity = v.entity;
+ CrawlerTypes.last_commit_at = v.last_commit_at;
+ } : CrawlerTypes.commit_info_response_oldest_entity)
+
+let rec decode_commit_info_response json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "commit_info_response"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "error" ->
+ let json = Js.Dict.unsafeGet json "error" in
+ (CrawlerTypes.Error ((decode_commit_info_error json)) : CrawlerTypes.commit_info_response)
+ | "entity" ->
+ let json = Js.Dict.unsafeGet json "entity" in
+ (CrawlerTypes.Entity ((decode_commit_info_response_oldest_entity (Pbrt_bs.object_ json "commit_info_response" "Entity"))) : CrawlerTypes.commit_info_response)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+let rec encode_entity (v:CrawlerTypes.entity) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | CrawlerTypes.Organization_name v ->
+ Js.Dict.set json "organization_name" (Js.Json.string v);
+ | CrawlerTypes.Project_name v ->
+ Js.Dict.set json "project_name" (Js.Json.string v);
+ | CrawlerTypes.Project_issue_name v ->
+ Js.Dict.set json "project_issueName" (Js.Json.string v);
+ | CrawlerTypes.Td_name v ->
+ Js.Dict.set json "td_name" (Js.Json.string v);
+ | CrawlerTypes.User_name v ->
+ Js.Dict.set json "user_name" (Js.Json.string v);
+ end;
+ json
+
+let rec encode_entity_type (v:CrawlerTypes.entity_type) : string =
+ match v with
+ | CrawlerTypes.Entity_type_organization -> "ENTITY_TYPE_ORGANIZATION"
+ | CrawlerTypes.Entity_type_project -> "ENTITY_TYPE_PROJECT"
+ | CrawlerTypes.Entity_type_task_data -> "ENTITY_TYPE_TASK_DATA"
+ | CrawlerTypes.Entity_type_user -> "ENTITY_TYPE_USER"
+
+let rec encode_crawler_error (v:CrawlerTypes.crawler_error) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "message" (Js.Json.string v.CrawlerTypes.message);
+ Js.Dict.set json "body" (Js.Json.string v.CrawlerTypes.body);
+ begin match v.CrawlerTypes.created_at with
+ | None -> ()
+ | Some v ->
+ begin (* created_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "created_at" (Js.Json.string json');
+ end;
+ end;
+ json
+
+let rec encode_crawler_error_list (v:CrawlerTypes.crawler_error_list) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "crawler" (Js.Json.string v.CrawlerTypes.crawler);
+ begin match v.CrawlerTypes.entity with
+ | None -> ()
+ | Some v ->
+ begin (* entity field *)
+ let json' = encode_entity v in
+ Js.Dict.set json "entity" (Js.Json.object_ json');
+ end;
+ end;
+ begin (* errors field *)
+ let (errors':Js.Json.t) =
+ v.CrawlerTypes.errors
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> encode_crawler_error |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "errors" errors';
+ end;
+ json
+
+let rec encode_errors_request (v:CrawlerTypes.errors_request) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "index" (Js.Json.string v.CrawlerTypes.index);
+ Js.Dict.set json "query" (Js.Json.string v.CrawlerTypes.query);
+ json
+
+let rec encode_errors_list (v:CrawlerTypes.errors_list) =
+ let json = Js.Dict.empty () in
+ begin (* errors field *)
+ let (errors':Js.Json.t) =
+ v.CrawlerTypes.errors
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> encode_crawler_error_list |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "errors" errors';
+ end;
+ json
+
+let rec encode_errors_response (v:CrawlerTypes.errors_response) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | CrawlerTypes.Success v ->
+ begin (* success field *)
+ let json' = encode_errors_list v in
+ Js.Dict.set json "success" (Js.Json.object_ json');
+ end;
+ | CrawlerTypes.Error v ->
+ Js.Dict.set json "error" (Js.Json.string v);
+ end;
+ json
+
+let rec encode_project (v:CrawlerTypes.project) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "full_path" (Js.Json.string v.CrawlerTypes.full_path);
+ json
+
+let rec encode_add_doc_request (v:CrawlerTypes.add_doc_request) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "index" (Js.Json.string v.CrawlerTypes.index);
+ Js.Dict.set json "crawler" (Js.Json.string v.CrawlerTypes.crawler);
+ Js.Dict.set json "apikey" (Js.Json.string v.CrawlerTypes.apikey);
+ begin match v.CrawlerTypes.entity with
+ | None -> ()
+ | Some v ->
+ begin (* entity field *)
+ let json' = encode_entity v in
+ Js.Dict.set json "entity" (Js.Json.object_ json');
+ end;
+ end;
+ begin (* changes field *)
+ let (changes':Js.Json.t) =
+ v.CrawlerTypes.changes
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> ChangeBs.encode_change |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "changes" changes';
+ end;
+ begin (* events field *)
+ let (events':Js.Json.t) =
+ v.CrawlerTypes.events
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> ChangeBs.encode_change_event |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "events" events';
+ end;
+ begin (* projects field *)
+ let (projects':Js.Json.t) =
+ v.CrawlerTypes.projects
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> encode_project |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "projects" projects';
+ end;
+ begin (* taskDatas field *)
+ let (task_datas':Js.Json.t) =
+ v.CrawlerTypes.task_datas
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> SearchBs.encode_task_data |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "task_datas" task_datas';
+ end;
+ begin (* issues field *)
+ let (issues':Js.Json.t) =
+ v.CrawlerTypes.issues
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> IssueBs.encode_issue |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "issues" issues';
+ end;
+ begin (* issueEvents field *)
+ let (issue_events':Js.Json.t) =
+ v.CrawlerTypes.issue_events
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> IssueBs.encode_issue_event |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "issue_events" issue_events';
+ end;
+ begin (* errors field *)
+ let (errors':Js.Json.t) =
+ v.CrawlerTypes.errors
+ |> Array.of_list
+ |> Array.map (fun v ->
+ v |> encode_crawler_error |> Js.Json.object_
+ )
+ |> Js.Json.array
+ in
+ Js.Dict.set json "errors" errors';
+ end;
+ json
+
+let rec encode_add_doc_error (v:CrawlerTypes.add_doc_error) : string =
+ match v with
+ | CrawlerTypes.Add_unknown_index -> "AddUnknownIndex"
+ | CrawlerTypes.Add_unknown_crawler -> "AddUnknownCrawler"
+ | CrawlerTypes.Add_unknown_api_key -> "AddUnknownApiKey"
+ | CrawlerTypes.Add_failed -> "AddFailed"
+
+let rec encode_add_doc_response (v:CrawlerTypes.add_doc_response) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | CrawlerTypes.Error v ->
+ Js.Dict.set json "error" (Js.Json.string (encode_add_doc_error v));
+ end;
+ json
+
+let rec encode_commit_request (v:CrawlerTypes.commit_request) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "index" (Js.Json.string v.CrawlerTypes.index);
+ Js.Dict.set json "crawler" (Js.Json.string v.CrawlerTypes.crawler);
+ Js.Dict.set json "apikey" (Js.Json.string v.CrawlerTypes.apikey);
+ begin match v.CrawlerTypes.entity with
+ | None -> ()
+ | Some v ->
+ begin (* entity field *)
+ let json' = encode_entity v in
+ Js.Dict.set json "entity" (Js.Json.object_ json');
+ end;
+ end;
+ begin match v.CrawlerTypes.timestamp with
+ | None -> ()
+ | Some v ->
+ begin (* timestamp field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "timestamp" (Js.Json.string json');
+ end;
+ end;
+ json
+
+let rec encode_commit_error (v:CrawlerTypes.commit_error) : string =
+ match v with
+ | CrawlerTypes.Commit_unknown_index -> "CommitUnknownIndex"
+ | CrawlerTypes.Commit_unknown_crawler -> "CommitUnknownCrawler"
+ | CrawlerTypes.Commit_unknown_api_key -> "CommitUnknownApiKey"
+ | CrawlerTypes.Commit_date_inferior_than_previous -> "CommitDateInferiorThanPrevious"
+ | CrawlerTypes.Commit_date_missing -> "CommitDateMissing"
+
+let rec encode_commit_response (v:CrawlerTypes.commit_response) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | CrawlerTypes.Error v ->
+ Js.Dict.set json "error" (Js.Json.string (encode_commit_error v));
+ | CrawlerTypes.Timestamp v ->
+ begin (* timestamp field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "timestamp" (Js.Json.string json');
+ end;
+ end;
+ json
+
+let rec encode_commit_info_request (v:CrawlerTypes.commit_info_request) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "index" (Js.Json.string v.CrawlerTypes.index);
+ Js.Dict.set json "crawler" (Js.Json.string v.CrawlerTypes.crawler);
+ Js.Dict.set json "entity" (Js.Json.string (encode_entity_type v.CrawlerTypes.entity));
+ Js.Dict.set json "offset" (Js.Json.number (Int32.to_float v.CrawlerTypes.offset));
+ json
+
+let rec encode_commit_info_error (v:CrawlerTypes.commit_info_error) : string =
+ match v with
+ | CrawlerTypes.Commit_get_unknown_index -> "CommitGetUnknownIndex"
+ | CrawlerTypes.Commit_get_unknown_crawler -> "CommitGetUnknownCrawler"
+ | CrawlerTypes.Commit_get_no_entity -> "CommitGetNoEntity"
+
+let rec encode_commit_info_response_oldest_entity (v:CrawlerTypes.commit_info_response_oldest_entity) =
+ let json = Js.Dict.empty () in
+ begin match v.CrawlerTypes.entity with
+ | None -> ()
+ | Some v ->
+ begin (* entity field *)
+ let json' = encode_entity v in
+ Js.Dict.set json "entity" (Js.Json.object_ json');
+ end;
+ end;
+ begin match v.CrawlerTypes.last_commit_at with
+ | None -> ()
+ | Some v ->
+ begin (* lastCommitAt field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "last_commit_at" (Js.Json.string json');
+ end;
+ end;
+ json
+
+let rec encode_commit_info_response (v:CrawlerTypes.commit_info_response) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | CrawlerTypes.Error v ->
+ Js.Dict.set json "error" (Js.Json.string (encode_commit_info_error v));
+ | CrawlerTypes.Entity v ->
+ begin (* entity field *)
+ let json' = encode_commit_info_response_oldest_entity v in
+ Js.Dict.set json "entity" (Js.Json.object_ json');
+ end;
+ end;
+ json
diff --git a/web/src/messages/CrawlerBs.mli b/web/src/messages/CrawlerBs.mli
new file mode 100644
index 000000000..d625e6727
--- /dev/null
+++ b/web/src/messages/CrawlerBs.mli
@@ -0,0 +1,115 @@
+(** crawler.proto BuckleScript Encoding *)
+
+
+(** {2 Protobuf JSON Encoding} *)
+
+val encode_entity : CrawlerTypes.entity -> Js.Json.t Js.Dict.t
+(** [encode_entity v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_entity_type : CrawlerTypes.entity_type -> string
+(** [encode_entity_type v] returns JSON string*)
+
+val encode_crawler_error : CrawlerTypes.crawler_error -> Js.Json.t Js.Dict.t
+(** [encode_crawler_error v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_crawler_error_list : CrawlerTypes.crawler_error_list -> Js.Json.t Js.Dict.t
+(** [encode_crawler_error_list v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_errors_request : CrawlerTypes.errors_request -> Js.Json.t Js.Dict.t
+(** [encode_errors_request v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_errors_list : CrawlerTypes.errors_list -> Js.Json.t Js.Dict.t
+(** [encode_errors_list v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_errors_response : CrawlerTypes.errors_response -> Js.Json.t Js.Dict.t
+(** [encode_errors_response v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_project : CrawlerTypes.project -> Js.Json.t Js.Dict.t
+(** [encode_project v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_add_doc_request : CrawlerTypes.add_doc_request -> Js.Json.t Js.Dict.t
+(** [encode_add_doc_request v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_add_doc_error : CrawlerTypes.add_doc_error -> string
+(** [encode_add_doc_error v] returns JSON string*)
+
+val encode_add_doc_response : CrawlerTypes.add_doc_response -> Js.Json.t Js.Dict.t
+(** [encode_add_doc_response v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_commit_request : CrawlerTypes.commit_request -> Js.Json.t Js.Dict.t
+(** [encode_commit_request v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_commit_error : CrawlerTypes.commit_error -> string
+(** [encode_commit_error v] returns JSON string*)
+
+val encode_commit_response : CrawlerTypes.commit_response -> Js.Json.t Js.Dict.t
+(** [encode_commit_response v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_commit_info_request : CrawlerTypes.commit_info_request -> Js.Json.t Js.Dict.t
+(** [encode_commit_info_request v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_commit_info_error : CrawlerTypes.commit_info_error -> string
+(** [encode_commit_info_error v] returns JSON string*)
+
+val encode_commit_info_response_oldest_entity : CrawlerTypes.commit_info_response_oldest_entity -> Js.Json.t Js.Dict.t
+(** [encode_commit_info_response_oldest_entity v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_commit_info_response : CrawlerTypes.commit_info_response -> Js.Json.t Js.Dict.t
+(** [encode_commit_info_response v dict] encodes [v] int the given JSON [dict] *)
+
+
+(** {2 BS Decoding} *)
+
+val decode_entity : Js.Json.t Js.Dict.t -> CrawlerTypes.entity
+(** [decode_entity decoder] decodes a [entity] value from [decoder] *)
+
+val decode_entity_type : Js.Json.t -> CrawlerTypes.entity_type
+(** [decode_entity_type value] decodes a [entity_type] from a Json value*)
+
+val decode_crawler_error : Js.Json.t Js.Dict.t -> CrawlerTypes.crawler_error
+(** [decode_crawler_error decoder] decodes a [crawler_error] value from [decoder] *)
+
+val decode_crawler_error_list : Js.Json.t Js.Dict.t -> CrawlerTypes.crawler_error_list
+(** [decode_crawler_error_list decoder] decodes a [crawler_error_list] value from [decoder] *)
+
+val decode_errors_request : Js.Json.t Js.Dict.t -> CrawlerTypes.errors_request
+(** [decode_errors_request decoder] decodes a [errors_request] value from [decoder] *)
+
+val decode_errors_list : Js.Json.t Js.Dict.t -> CrawlerTypes.errors_list
+(** [decode_errors_list decoder] decodes a [errors_list] value from [decoder] *)
+
+val decode_errors_response : Js.Json.t Js.Dict.t -> CrawlerTypes.errors_response
+(** [decode_errors_response decoder] decodes a [errors_response] value from [decoder] *)
+
+val decode_project : Js.Json.t Js.Dict.t -> CrawlerTypes.project
+(** [decode_project decoder] decodes a [project] value from [decoder] *)
+
+val decode_add_doc_request : Js.Json.t Js.Dict.t -> CrawlerTypes.add_doc_request
+(** [decode_add_doc_request decoder] decodes a [add_doc_request] value from [decoder] *)
+
+val decode_add_doc_error : Js.Json.t -> CrawlerTypes.add_doc_error
+(** [decode_add_doc_error value] decodes a [add_doc_error] from a Json value*)
+
+val decode_add_doc_response : Js.Json.t Js.Dict.t -> CrawlerTypes.add_doc_response
+(** [decode_add_doc_response decoder] decodes a [add_doc_response] value from [decoder] *)
+
+val decode_commit_request : Js.Json.t Js.Dict.t -> CrawlerTypes.commit_request
+(** [decode_commit_request decoder] decodes a [commit_request] value from [decoder] *)
+
+val decode_commit_error : Js.Json.t -> CrawlerTypes.commit_error
+(** [decode_commit_error value] decodes a [commit_error] from a Json value*)
+
+val decode_commit_response : Js.Json.t Js.Dict.t -> CrawlerTypes.commit_response
+(** [decode_commit_response decoder] decodes a [commit_response] value from [decoder] *)
+
+val decode_commit_info_request : Js.Json.t Js.Dict.t -> CrawlerTypes.commit_info_request
+(** [decode_commit_info_request decoder] decodes a [commit_info_request] value from [decoder] *)
+
+val decode_commit_info_error : Js.Json.t -> CrawlerTypes.commit_info_error
+(** [decode_commit_info_error value] decodes a [commit_info_error] from a Json value*)
+
+val decode_commit_info_response_oldest_entity : Js.Json.t Js.Dict.t -> CrawlerTypes.commit_info_response_oldest_entity
+(** [decode_commit_info_response_oldest_entity decoder] decodes a [commit_info_response_oldest_entity] value from [decoder] *)
+
+val decode_commit_info_response : Js.Json.t Js.Dict.t -> CrawlerTypes.commit_info_response
+(** [decode_commit_info_response decoder] decodes a [commit_info_response] value from [decoder] *)
diff --git a/web/src/messages/CrawlerTypes.ml b/web/src/messages/CrawlerTypes.ml
new file mode 100644
index 000000000..481404548
--- /dev/null
+++ b/web/src/messages/CrawlerTypes.ml
@@ -0,0 +1,225 @@
+[@@@ocaml.warning "-27-30-39"]
+
+
+type entity =
+ | Organization_name of string
+ | Project_name of string
+ | Project_issue_name of string
+ | Td_name of string
+ | User_name of string
+
+type entity_type =
+ | Entity_type_organization
+ | Entity_type_project
+ | Entity_type_task_data
+ | Entity_type_user
+
+type crawler_error = {
+ message : string;
+ body : string;
+ created_at : TimestampTypes.timestamp option;
+}
+
+type crawler_error_list = {
+ crawler : string;
+ entity : entity option;
+ errors : crawler_error list;
+}
+
+type errors_request = {
+ index : string;
+ query : string;
+}
+
+type errors_list = {
+ errors : crawler_error_list list;
+}
+
+type errors_response =
+ | Success of errors_list
+ | Error of string
+
+type project = {
+ full_path : string;
+}
+
+type add_doc_request = {
+ index : string;
+ crawler : string;
+ apikey : string;
+ entity : entity option;
+ changes : ChangeTypes.change list;
+ events : ChangeTypes.change_event list;
+ projects : project list;
+ task_datas : SearchTypes.task_data list;
+ issues : IssueTypes.issue list;
+ issue_events : IssueTypes.issue_event list;
+ errors : crawler_error list;
+}
+
+type add_doc_error =
+ | Add_unknown_index
+ | Add_unknown_crawler
+ | Add_unknown_api_key
+ | Add_failed
+
+type add_doc_response =
+ | Error of add_doc_error
+
+type commit_request = {
+ index : string;
+ crawler : string;
+ apikey : string;
+ entity : entity option;
+ timestamp : TimestampTypes.timestamp option;
+}
+
+type commit_error =
+ | Commit_unknown_index
+ | Commit_unknown_crawler
+ | Commit_unknown_api_key
+ | Commit_date_inferior_than_previous
+ | Commit_date_missing
+
+type commit_response =
+ | Error of commit_error
+ | Timestamp of TimestampTypes.timestamp
+
+type commit_info_request = {
+ index : string;
+ crawler : string;
+ entity : entity_type;
+ offset : int32;
+}
+
+type commit_info_error =
+ | Commit_get_unknown_index
+ | Commit_get_unknown_crawler
+ | Commit_get_no_entity
+
+type commit_info_response_oldest_entity = {
+ entity : entity option;
+ last_commit_at : TimestampTypes.timestamp option;
+}
+
+type commit_info_response =
+ | Error of commit_info_error
+ | Entity of commit_info_response_oldest_entity
+
+let rec default_entity () : entity = Organization_name ("")
+
+let rec default_entity_type () = (Entity_type_organization:entity_type)
+
+let rec default_crawler_error
+ ?message:((message:string) = "")
+ ?body:((body:string) = "")
+ ?created_at:((created_at:TimestampTypes.timestamp option) = None)
+ () : crawler_error = {
+ message;
+ body;
+ created_at;
+}
+
+let rec default_crawler_error_list
+ ?crawler:((crawler:string) = "")
+ ?entity:((entity:entity option) = None)
+ ?errors:((errors:crawler_error list) = [])
+ () : crawler_error_list = {
+ crawler;
+ entity;
+ errors;
+}
+
+let rec default_errors_request
+ ?index:((index:string) = "")
+ ?query:((query:string) = "")
+ () : errors_request = {
+ index;
+ query;
+}
+
+let rec default_errors_list
+ ?errors:((errors:crawler_error_list list) = [])
+ () : errors_list = {
+ errors;
+}
+
+let rec default_errors_response () : errors_response = Success (default_errors_list ())
+
+let rec default_project
+ ?full_path:((full_path:string) = "")
+ () : project = {
+ full_path;
+}
+
+let rec default_add_doc_request
+ ?index:((index:string) = "")
+ ?crawler:((crawler:string) = "")
+ ?apikey:((apikey:string) = "")
+ ?entity:((entity:entity option) = None)
+ ?changes:((changes:ChangeTypes.change list) = [])
+ ?events:((events:ChangeTypes.change_event list) = [])
+ ?projects:((projects:project list) = [])
+ ?task_datas:((task_datas:SearchTypes.task_data list) = [])
+ ?issues:((issues:IssueTypes.issue list) = [])
+ ?issue_events:((issue_events:IssueTypes.issue_event list) = [])
+ ?errors:((errors:crawler_error list) = [])
+ () : add_doc_request = {
+ index;
+ crawler;
+ apikey;
+ entity;
+ changes;
+ events;
+ projects;
+ task_datas;
+ issues;
+ issue_events;
+ errors;
+}
+
+let rec default_add_doc_error () = (Add_unknown_index:add_doc_error)
+
+let rec default_add_doc_response () : add_doc_response = Error (default_add_doc_error ())
+
+let rec default_commit_request
+ ?index:((index:string) = "")
+ ?crawler:((crawler:string) = "")
+ ?apikey:((apikey:string) = "")
+ ?entity:((entity:entity option) = None)
+ ?timestamp:((timestamp:TimestampTypes.timestamp option) = None)
+ () : commit_request = {
+ index;
+ crawler;
+ apikey;
+ entity;
+ timestamp;
+}
+
+let rec default_commit_error () = (Commit_unknown_index:commit_error)
+
+let rec default_commit_response () : commit_response = Error (default_commit_error ())
+
+let rec default_commit_info_request
+ ?index:((index:string) = "")
+ ?crawler:((crawler:string) = "")
+ ?entity:((entity:entity_type) = default_entity_type ())
+ ?offset:((offset:int32) = 0l)
+ () : commit_info_request = {
+ index;
+ crawler;
+ entity;
+ offset;
+}
+
+let rec default_commit_info_error () = (Commit_get_unknown_index:commit_info_error)
+
+let rec default_commit_info_response_oldest_entity
+ ?entity:((entity:entity option) = None)
+ ?last_commit_at:((last_commit_at:TimestampTypes.timestamp option) = None)
+ () : commit_info_response_oldest_entity = {
+ entity;
+ last_commit_at;
+}
+
+let rec default_commit_info_response () : commit_info_response = Error (default_commit_info_error ())
diff --git a/web/src/messages/CrawlerTypes.mli b/web/src/messages/CrawlerTypes.mli
new file mode 100644
index 000000000..c7777f5f7
--- /dev/null
+++ b/web/src/messages/CrawlerTypes.mli
@@ -0,0 +1,217 @@
+(** crawler.proto Types *)
+
+
+
+(** {2 Types} *)
+
+type entity =
+ | Organization_name of string
+ | Project_name of string
+ | Project_issue_name of string
+ | Td_name of string
+ | User_name of string
+
+type entity_type =
+ | Entity_type_organization
+ | Entity_type_project
+ | Entity_type_task_data
+ | Entity_type_user
+
+type crawler_error = {
+ message : string;
+ body : string;
+ created_at : TimestampTypes.timestamp option;
+}
+
+type crawler_error_list = {
+ crawler : string;
+ entity : entity option;
+ errors : crawler_error list;
+}
+
+type errors_request = {
+ index : string;
+ query : string;
+}
+
+type errors_list = {
+ errors : crawler_error_list list;
+}
+
+type errors_response =
+ | Success of errors_list
+ | Error of string
+
+type project = {
+ full_path : string;
+}
+
+type add_doc_request = {
+ index : string;
+ crawler : string;
+ apikey : string;
+ entity : entity option;
+ changes : ChangeTypes.change list;
+ events : ChangeTypes.change_event list;
+ projects : project list;
+ task_datas : SearchTypes.task_data list;
+ issues : IssueTypes.issue list;
+ issue_events : IssueTypes.issue_event list;
+ errors : crawler_error list;
+}
+
+type add_doc_error =
+ | Add_unknown_index
+ | Add_unknown_crawler
+ | Add_unknown_api_key
+ | Add_failed
+
+type add_doc_response =
+ | Error of add_doc_error
+
+type commit_request = {
+ index : string;
+ crawler : string;
+ apikey : string;
+ entity : entity option;
+ timestamp : TimestampTypes.timestamp option;
+}
+
+type commit_error =
+ | Commit_unknown_index
+ | Commit_unknown_crawler
+ | Commit_unknown_api_key
+ | Commit_date_inferior_than_previous
+ | Commit_date_missing
+
+type commit_response =
+ | Error of commit_error
+ | Timestamp of TimestampTypes.timestamp
+
+type commit_info_request = {
+ index : string;
+ crawler : string;
+ entity : entity_type;
+ offset : int32;
+}
+
+type commit_info_error =
+ | Commit_get_unknown_index
+ | Commit_get_unknown_crawler
+ | Commit_get_no_entity
+
+type commit_info_response_oldest_entity = {
+ entity : entity option;
+ last_commit_at : TimestampTypes.timestamp option;
+}
+
+type commit_info_response =
+ | Error of commit_info_error
+ | Entity of commit_info_response_oldest_entity
+
+
+(** {2 Default values} *)
+
+val default_entity : unit -> entity
+(** [default_entity ()] is the default value for type [entity] *)
+
+val default_entity_type : unit -> entity_type
+(** [default_entity_type ()] is the default value for type [entity_type] *)
+
+val default_crawler_error :
+ ?message:string ->
+ ?body:string ->
+ ?created_at:TimestampTypes.timestamp option ->
+ unit ->
+ crawler_error
+(** [default_crawler_error ()] is the default value for type [crawler_error] *)
+
+val default_crawler_error_list :
+ ?crawler:string ->
+ ?entity:entity option ->
+ ?errors:crawler_error list ->
+ unit ->
+ crawler_error_list
+(** [default_crawler_error_list ()] is the default value for type [crawler_error_list] *)
+
+val default_errors_request :
+ ?index:string ->
+ ?query:string ->
+ unit ->
+ errors_request
+(** [default_errors_request ()] is the default value for type [errors_request] *)
+
+val default_errors_list :
+ ?errors:crawler_error_list list ->
+ unit ->
+ errors_list
+(** [default_errors_list ()] is the default value for type [errors_list] *)
+
+val default_errors_response : unit -> errors_response
+(** [default_errors_response ()] is the default value for type [errors_response] *)
+
+val default_project :
+ ?full_path:string ->
+ unit ->
+ project
+(** [default_project ()] is the default value for type [project] *)
+
+val default_add_doc_request :
+ ?index:string ->
+ ?crawler:string ->
+ ?apikey:string ->
+ ?entity:entity option ->
+ ?changes:ChangeTypes.change list ->
+ ?events:ChangeTypes.change_event list ->
+ ?projects:project list ->
+ ?task_datas:SearchTypes.task_data list ->
+ ?issues:IssueTypes.issue list ->
+ ?issue_events:IssueTypes.issue_event list ->
+ ?errors:crawler_error list ->
+ unit ->
+ add_doc_request
+(** [default_add_doc_request ()] is the default value for type [add_doc_request] *)
+
+val default_add_doc_error : unit -> add_doc_error
+(** [default_add_doc_error ()] is the default value for type [add_doc_error] *)
+
+val default_add_doc_response : unit -> add_doc_response
+(** [default_add_doc_response ()] is the default value for type [add_doc_response] *)
+
+val default_commit_request :
+ ?index:string ->
+ ?crawler:string ->
+ ?apikey:string ->
+ ?entity:entity option ->
+ ?timestamp:TimestampTypes.timestamp option ->
+ unit ->
+ commit_request
+(** [default_commit_request ()] is the default value for type [commit_request] *)
+
+val default_commit_error : unit -> commit_error
+(** [default_commit_error ()] is the default value for type [commit_error] *)
+
+val default_commit_response : unit -> commit_response
+(** [default_commit_response ()] is the default value for type [commit_response] *)
+
+val default_commit_info_request :
+ ?index:string ->
+ ?crawler:string ->
+ ?entity:entity_type ->
+ ?offset:int32 ->
+ unit ->
+ commit_info_request
+(** [default_commit_info_request ()] is the default value for type [commit_info_request] *)
+
+val default_commit_info_error : unit -> commit_info_error
+(** [default_commit_info_error ()] is the default value for type [commit_info_error] *)
+
+val default_commit_info_response_oldest_entity :
+ ?entity:entity option ->
+ ?last_commit_at:TimestampTypes.timestamp option ->
+ unit ->
+ commit_info_response_oldest_entity
+(** [default_commit_info_response_oldest_entity ()] is the default value for type [commit_info_response_oldest_entity] *)
+
+val default_commit_info_response : unit -> commit_info_response
+(** [default_commit_info_response ()] is the default value for type [commit_info_response] *)
diff --git a/web/src/messages/IssueBs.ml b/web/src/messages/IssueBs.ml
new file mode 100644
index 000000000..2d05238fd
--- /dev/null
+++ b/web/src/messages/IssueBs.ml
@@ -0,0 +1,376 @@
+[@@@ocaml.warning "-27-30-39"]
+
+type ident_mutable = {
+ mutable uid : string;
+ mutable muid : string;
+}
+
+let default_ident_mutable () : ident_mutable = {
+ uid = "";
+ muid = "";
+}
+
+type issue_mutable = {
+ mutable id : string;
+ mutable number : int32;
+ mutable title : string;
+ mutable text : string;
+ mutable url : string;
+ mutable repository_prefix : string;
+ mutable repository_fullname : string;
+ mutable repository_shortname : string;
+ mutable author : ChangeTypes.ident option;
+ mutable created_at : TimestampTypes.timestamp option;
+ mutable updated_at : TimestampTypes.timestamp option;
+ mutable optional_closed_at : IssueTypes.issue_optional_closed_at;
+ mutable state : string;
+}
+
+let default_issue_mutable () : issue_mutable = {
+ id = "";
+ number = 0l;
+ title = "";
+ text = "";
+ url = "";
+ repository_prefix = "";
+ repository_fullname = "";
+ repository_shortname = "";
+ author = None;
+ created_at = None;
+ updated_at = None;
+ optional_closed_at = IssueTypes.Closed_at (TimestampTypes.default_timestamp);
+ state = "";
+}
+
+type issue_commented_event_mutable = {
+ mutable comment : string;
+}
+
+let default_issue_commented_event_mutable () : issue_commented_event_mutable = {
+ comment = "";
+}
+
+type issue_event_mutable = {
+ mutable id : string;
+ mutable created_at : TimestampTypes.timestamp option;
+ mutable author : ChangeTypes.ident option;
+ mutable repository_prefix : string;
+ mutable repository_fullname : string;
+ mutable repository_shortname : string;
+ mutable number : int32;
+ mutable url : string;
+ mutable type_ : IssueTypes.issue_event_type;
+}
+
+let default_issue_event_mutable () : issue_event_mutable = {
+ id = "";
+ created_at = None;
+ author = None;
+ repository_prefix = "";
+ repository_fullname = "";
+ repository_shortname = "";
+ number = 0l;
+ url = "";
+ type_ = IssueTypes.Issue_created;
+}
+
+
+let rec decode_ident json =
+ let v = default_ident_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "uid" ->
+ let json = Js.Dict.unsafeGet json "uid" in
+ v.uid <- Pbrt_bs.string json "ident" "uid"
+ | "muid" ->
+ let json = Js.Dict.unsafeGet json "muid" in
+ v.muid <- Pbrt_bs.string json "ident" "muid"
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ IssueTypes.uid = v.uid;
+ IssueTypes.muid = v.muid;
+ } : IssueTypes.ident)
+
+let rec decode_issue_optional_closed_at json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "issue_optional_closed_at"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "closed_at" ->
+ let json = Js.Dict.unsafeGet json "closed_at" in
+ (IssueTypes.Closed_at ((TimestampBs.decode_timestamp (Pbrt_bs.string json "issue_optional_closed_at" "Closed_at"))) : IssueTypes.issue_optional_closed_at)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+and decode_issue json =
+ let v = default_issue_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "id" ->
+ let json = Js.Dict.unsafeGet json "id" in
+ v.id <- Pbrt_bs.string json "issue" "id"
+ | "number" ->
+ let json = Js.Dict.unsafeGet json "number" in
+ v.number <- Pbrt_bs.int32 json "issue" "number"
+ | "title" ->
+ let json = Js.Dict.unsafeGet json "title" in
+ v.title <- Pbrt_bs.string json "issue" "title"
+ | "text" ->
+ let json = Js.Dict.unsafeGet json "text" in
+ v.text <- Pbrt_bs.string json "issue" "text"
+ | "url" ->
+ let json = Js.Dict.unsafeGet json "url" in
+ v.url <- Pbrt_bs.string json "issue" "url"
+ | "repository_prefix" ->
+ let json = Js.Dict.unsafeGet json "repository_prefix" in
+ v.repository_prefix <- Pbrt_bs.string json "issue" "repository_prefix"
+ | "repository_fullname" ->
+ let json = Js.Dict.unsafeGet json "repository_fullname" in
+ v.repository_fullname <- Pbrt_bs.string json "issue" "repository_fullname"
+ | "repository_shortname" ->
+ let json = Js.Dict.unsafeGet json "repository_shortname" in
+ v.repository_shortname <- Pbrt_bs.string json "issue" "repository_shortname"
+ | "author" ->
+ let json = Js.Dict.unsafeGet json "author" in
+ v.author <- Some ((ChangeBs.decode_ident (Pbrt_bs.object_ json "issue" "author")))
+ | "created_at" ->
+ let json = Js.Dict.unsafeGet json "created_at" in
+ v.created_at <- Some ((TimestampBs.decode_timestamp (Pbrt_bs.string json "issue" "created_at")))
+ | "updated_at" ->
+ let json = Js.Dict.unsafeGet json "updated_at" in
+ v.updated_at <- Some ((TimestampBs.decode_timestamp (Pbrt_bs.string json "issue" "updated_at")))
+ | "closed_at" ->
+ let json = Js.Dict.unsafeGet json "closed_at" in
+ v.optional_closed_at <- Closed_at ((TimestampBs.decode_timestamp (Pbrt_bs.string json "issue" "optional_closed_at")))
+ | "state" ->
+ let json = Js.Dict.unsafeGet json "state" in
+ v.state <- Pbrt_bs.string json "issue" "state"
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ IssueTypes.id = v.id;
+ IssueTypes.number = v.number;
+ IssueTypes.title = v.title;
+ IssueTypes.text = v.text;
+ IssueTypes.url = v.url;
+ IssueTypes.repository_prefix = v.repository_prefix;
+ IssueTypes.repository_fullname = v.repository_fullname;
+ IssueTypes.repository_shortname = v.repository_shortname;
+ IssueTypes.author = v.author;
+ IssueTypes.created_at = v.created_at;
+ IssueTypes.updated_at = v.updated_at;
+ IssueTypes.optional_closed_at = v.optional_closed_at;
+ IssueTypes.state = v.state;
+ } : IssueTypes.issue)
+
+let rec decode_issue_commented_event json =
+ let v = default_issue_commented_event_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "comment" ->
+ let json = Js.Dict.unsafeGet json "comment" in
+ v.comment <- Pbrt_bs.string json "issue_commented_event" "comment"
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ IssueTypes.comment = v.comment;
+ } : IssueTypes.issue_commented_event)
+
+let rec decode_issue_event_type json =
+ let keys = Js.Dict.keys json in
+ let rec loop = function
+ | -1 -> Pbrt_bs.E.malformed_variant "issue_event_type"
+ | i ->
+ begin match Array.unsafe_get keys i with
+ | "issue_created" -> (IssueTypes.Issue_created : IssueTypes.issue_event_type)
+ | "issue_commented" ->
+ let json = Js.Dict.unsafeGet json "issue_commented" in
+ (IssueTypes.Issue_commented ((decode_issue_commented_event (Pbrt_bs.object_ json "issue_event_type" "Issue_commented"))) : IssueTypes.issue_event_type)
+ | "issue_closed" -> (IssueTypes.Issue_closed : IssueTypes.issue_event_type)
+
+ | _ -> loop (i - 1)
+ end
+ in
+ loop (Array.length keys - 1)
+
+and decode_issue_event json =
+ let v = default_issue_event_mutable () in
+ let keys = Js.Dict.keys json in
+ let last_key_index = Array.length keys - 1 in
+ for i = 0 to last_key_index do
+ match Array.unsafe_get keys i with
+ | "id" ->
+ let json = Js.Dict.unsafeGet json "id" in
+ v.id <- Pbrt_bs.string json "issue_event" "id"
+ | "created_at" ->
+ let json = Js.Dict.unsafeGet json "created_at" in
+ v.created_at <- Some ((TimestampBs.decode_timestamp (Pbrt_bs.string json "issue_event" "created_at")))
+ | "author" ->
+ let json = Js.Dict.unsafeGet json "author" in
+ v.author <- Some ((ChangeBs.decode_ident (Pbrt_bs.object_ json "issue_event" "author")))
+ | "repository_prefix" ->
+ let json = Js.Dict.unsafeGet json "repository_prefix" in
+ v.repository_prefix <- Pbrt_bs.string json "issue_event" "repository_prefix"
+ | "repository_fullname" ->
+ let json = Js.Dict.unsafeGet json "repository_fullname" in
+ v.repository_fullname <- Pbrt_bs.string json "issue_event" "repository_fullname"
+ | "repository_shortname" ->
+ let json = Js.Dict.unsafeGet json "repository_shortname" in
+ v.repository_shortname <- Pbrt_bs.string json "issue_event" "repository_shortname"
+ | "number" ->
+ let json = Js.Dict.unsafeGet json "number" in
+ v.number <- Pbrt_bs.int32 json "issue_event" "number"
+ | "url" ->
+ let json = Js.Dict.unsafeGet json "url" in
+ v.url <- Pbrt_bs.string json "issue_event" "url"
+ | "issue_created" -> v.type_ <- Issue_created
+ | "issue_commented" ->
+ let json = Js.Dict.unsafeGet json "issue_commented" in
+ v.type_ <- Issue_commented ((decode_issue_commented_event (Pbrt_bs.object_ json "issue_event" "type_")))
+ | "issue_closed" -> v.type_ <- Issue_closed
+
+ | _ -> () (*Unknown fields are ignored*)
+ done;
+ ({
+ IssueTypes.id = v.id;
+ IssueTypes.created_at = v.created_at;
+ IssueTypes.author = v.author;
+ IssueTypes.repository_prefix = v.repository_prefix;
+ IssueTypes.repository_fullname = v.repository_fullname;
+ IssueTypes.repository_shortname = v.repository_shortname;
+ IssueTypes.number = v.number;
+ IssueTypes.url = v.url;
+ IssueTypes.type_ = v.type_;
+ } : IssueTypes.issue_event)
+
+let rec encode_ident (v:IssueTypes.ident) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "uid" (Js.Json.string v.IssueTypes.uid);
+ Js.Dict.set json "muid" (Js.Json.string v.IssueTypes.muid);
+ json
+
+let rec encode_issue_optional_closed_at (v:IssueTypes.issue_optional_closed_at) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | IssueTypes.Closed_at v ->
+ begin (* closed_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "closed_at" (Js.Json.string json');
+ end;
+ end;
+ json
+
+and encode_issue (v:IssueTypes.issue) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "id" (Js.Json.string v.IssueTypes.id);
+ Js.Dict.set json "number" (Js.Json.number (Int32.to_float v.IssueTypes.number));
+ Js.Dict.set json "title" (Js.Json.string v.IssueTypes.title);
+ Js.Dict.set json "text" (Js.Json.string v.IssueTypes.text);
+ Js.Dict.set json "url" (Js.Json.string v.IssueTypes.url);
+ Js.Dict.set json "repository_prefix" (Js.Json.string v.IssueTypes.repository_prefix);
+ Js.Dict.set json "repository_fullname" (Js.Json.string v.IssueTypes.repository_fullname);
+ Js.Dict.set json "repository_shortname" (Js.Json.string v.IssueTypes.repository_shortname);
+ begin match v.IssueTypes.author with
+ | None -> ()
+ | Some v ->
+ begin (* author field *)
+ let json' = ChangeBs.encode_ident v in
+ Js.Dict.set json "author" (Js.Json.object_ json');
+ end;
+ end;
+ begin match v.IssueTypes.created_at with
+ | None -> ()
+ | Some v ->
+ begin (* created_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "created_at" (Js.Json.string json');
+ end;
+ end;
+ begin match v.IssueTypes.updated_at with
+ | None -> ()
+ | Some v ->
+ begin (* updated_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "updated_at" (Js.Json.string json');
+ end;
+ end;
+ begin match v.IssueTypes.optional_closed_at with
+ | Closed_at v ->
+ begin (* closed_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "closed_at" (Js.Json.string json');
+ end;
+ end; (* match v.optional_closed_at *)
+ Js.Dict.set json "state" (Js.Json.string v.IssueTypes.state);
+ json
+
+let rec encode_issue_commented_event (v:IssueTypes.issue_commented_event) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "comment" (Js.Json.string v.IssueTypes.comment);
+ json
+
+let rec encode_issue_event_type (v:IssueTypes.issue_event_type) =
+ let json = Js.Dict.empty () in
+ begin match v with
+ | IssueTypes.Issue_created ->
+ Js.Dict.set json "issue_created" Js.Json.null
+ | IssueTypes.Issue_commented v ->
+ begin (* issueCommented field *)
+ let json' = encode_issue_commented_event v in
+ Js.Dict.set json "issue_commented" (Js.Json.object_ json');
+ end;
+ | IssueTypes.Issue_closed ->
+ Js.Dict.set json "issue_closed" Js.Json.null
+ end;
+ json
+
+and encode_issue_event (v:IssueTypes.issue_event) =
+ let json = Js.Dict.empty () in
+ Js.Dict.set json "id" (Js.Json.string v.IssueTypes.id);
+ begin match v.IssueTypes.created_at with
+ | None -> ()
+ | Some v ->
+ begin (* created_at field *)
+ let json' = TimestampBs.encode_timestamp v in
+ Js.Dict.set json "created_at" (Js.Json.string json');
+ end;
+ end;
+ begin match v.IssueTypes.author with
+ | None -> ()
+ | Some v ->
+ begin (* author field *)
+ let json' = ChangeBs.encode_ident v in
+ Js.Dict.set json "author" (Js.Json.object_ json');
+ end;
+ end;
+ Js.Dict.set json "repository_prefix" (Js.Json.string v.IssueTypes.repository_prefix);
+ Js.Dict.set json "repository_fullname" (Js.Json.string v.IssueTypes.repository_fullname);
+ Js.Dict.set json "repository_shortname" (Js.Json.string v.IssueTypes.repository_shortname);
+ Js.Dict.set json "number" (Js.Json.number (Int32.to_float v.IssueTypes.number));
+ Js.Dict.set json "url" (Js.Json.string v.IssueTypes.url);
+ begin match v.IssueTypes.type_ with
+ | Issue_created ->
+ Js.Dict.set json "issue_created" Js.Json.null
+ | Issue_commented v ->
+ begin (* issueCommented field *)
+ let json' = encode_issue_commented_event v in
+ Js.Dict.set json "issue_commented" (Js.Json.object_ json');
+ end;
+ | Issue_closed ->
+ Js.Dict.set json "issue_closed" Js.Json.null
+ end; (* match v.type_ *)
+ json
diff --git a/web/src/messages/IssueBs.mli b/web/src/messages/IssueBs.mli
new file mode 100644
index 000000000..b14edbbe8
--- /dev/null
+++ b/web/src/messages/IssueBs.mli
@@ -0,0 +1,43 @@
+(** issue.proto BuckleScript Encoding *)
+
+
+(** {2 Protobuf JSON Encoding} *)
+
+val encode_ident : IssueTypes.ident -> Js.Json.t Js.Dict.t
+(** [encode_ident v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_issue_optional_closed_at : IssueTypes.issue_optional_closed_at -> Js.Json.t Js.Dict.t
+(** [encode_issue_optional_closed_at v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_issue : IssueTypes.issue -> Js.Json.t Js.Dict.t
+(** [encode_issue v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_issue_commented_event : IssueTypes.issue_commented_event -> Js.Json.t Js.Dict.t
+(** [encode_issue_commented_event v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_issue_event_type : IssueTypes.issue_event_type -> Js.Json.t Js.Dict.t
+(** [encode_issue_event_type v dict] encodes [v] int the given JSON [dict] *)
+
+val encode_issue_event : IssueTypes.issue_event -> Js.Json.t Js.Dict.t
+(** [encode_issue_event v dict] encodes [v] int the given JSON [dict] *)
+
+
+(** {2 BS Decoding} *)
+
+val decode_ident : Js.Json.t Js.Dict.t -> IssueTypes.ident
+(** [decode_ident decoder] decodes a [ident] value from [decoder] *)
+
+val decode_issue_optional_closed_at : Js.Json.t Js.Dict.t -> IssueTypes.issue_optional_closed_at
+(** [decode_issue_optional_closed_at decoder] decodes a [issue_optional_closed_at] value from [decoder] *)
+
+val decode_issue : Js.Json.t Js.Dict.t -> IssueTypes.issue
+(** [decode_issue decoder] decodes a [issue] value from [decoder] *)
+
+val decode_issue_commented_event : Js.Json.t Js.Dict.t -> IssueTypes.issue_commented_event
+(** [decode_issue_commented_event decoder] decodes a [issue_commented_event] value from [decoder] *)
+
+val decode_issue_event_type : Js.Json.t Js.Dict.t -> IssueTypes.issue_event_type
+(** [decode_issue_event_type decoder] decodes a [issue_event_type] value from [decoder] *)
+
+val decode_issue_event : Js.Json.t Js.Dict.t -> IssueTypes.issue_event
+(** [decode_issue_event decoder] decodes a [issue_event] value from [decoder] *)
diff --git a/web/src/messages/IssueTypes.ml b/web/src/messages/IssueTypes.ml
new file mode 100644
index 000000000..76d42b15a
--- /dev/null
+++ b/web/src/messages/IssueTypes.ml
@@ -0,0 +1,117 @@
+[@@@ocaml.warning "-27-30-39"]
+
+
+type ident = {
+ uid : string;
+ muid : string;
+}
+
+type issue_optional_closed_at =
+ | Closed_at of TimestampTypes.timestamp
+
+and issue = {
+ id : string;
+ number : int32;
+ title : string;
+ text : string;
+ url : string;
+ repository_prefix : string;
+ repository_fullname : string;
+ repository_shortname : string;
+ author : ChangeTypes.ident option;
+ created_at : TimestampTypes.timestamp option;
+ updated_at : TimestampTypes.timestamp option;
+ optional_closed_at : issue_optional_closed_at;
+ state : string;
+}
+
+type issue_commented_event = {
+ comment : string;
+}
+
+type issue_event_type =
+ | Issue_created
+ | Issue_commented of issue_commented_event
+ | Issue_closed
+
+and issue_event = {
+ id : string;
+ created_at : TimestampTypes.timestamp option;
+ author : ChangeTypes.ident option;
+ repository_prefix : string;
+ repository_fullname : string;
+ repository_shortname : string;
+ number : int32;
+ url : string;
+ type_ : issue_event_type;
+}
+
+let rec default_ident
+ ?uid:((uid:string) = "")
+ ?muid:((muid:string) = "")
+ () : ident = {
+ uid;
+ muid;
+}
+
+let rec default_issue_optional_closed_at () : issue_optional_closed_at = Closed_at (TimestampTypes.default_timestamp)
+
+and default_issue
+ ?id:((id:string) = "")
+ ?number:((number:int32) = 0l)
+ ?title:((title:string) = "")
+ ?text:((text:string) = "")
+ ?url:((url:string) = "")
+ ?repository_prefix:((repository_prefix:string) = "")
+ ?repository_fullname:((repository_fullname:string) = "")
+ ?repository_shortname:((repository_shortname:string) = "")
+ ?author:((author:ChangeTypes.ident option) = None)
+ ?created_at:((created_at:TimestampTypes.timestamp option) = None)
+ ?updated_at:((updated_at:TimestampTypes.timestamp option) = None)
+ ?optional_closed_at:((optional_closed_at:issue_optional_closed_at) = Closed_at (TimestampTypes.default_timestamp))
+ ?state:((state:string) = "")
+ () : issue = {
+ id;
+ number;
+ title;
+ text;
+ url;
+ repository_prefix;
+ repository_fullname;
+ repository_shortname;
+ author;
+ created_at;
+ updated_at;
+ optional_closed_at;
+ state;
+}
+
+let rec default_issue_commented_event
+ ?comment:((comment:string) = "")
+ () : issue_commented_event = {
+ comment;
+}
+
+let rec default_issue_event_type (): issue_event_type = Issue_created
+
+and default_issue_event
+ ?id:((id:string) = "")
+ ?created_at:((created_at:TimestampTypes.timestamp option) = None)
+ ?author:((author:ChangeTypes.ident option) = None)
+ ?repository_prefix:((repository_prefix:string) = "")
+ ?repository_fullname:((repository_fullname:string) = "")
+ ?repository_shortname:((repository_shortname:string) = "")
+ ?number:((number:int32) = 0l)
+ ?url:((url:string) = "")
+ ?type_:((type_:issue_event_type) = Issue_created)
+ () : issue_event = {
+ id;
+ created_at;
+ author;
+ repository_prefix;
+ repository_fullname;
+ repository_shortname;
+ number;
+ url;
+ type_;
+}
diff --git a/web/src/messages/IssueTypes.mli b/web/src/messages/IssueTypes.mli
new file mode 100644
index 000000000..b6afb9f12
--- /dev/null
+++ b/web/src/messages/IssueTypes.mli
@@ -0,0 +1,104 @@
+(** issue.proto Types *)
+
+
+
+(** {2 Types} *)
+
+type ident = {
+ uid : string;
+ muid : string;
+}
+
+type issue_optional_closed_at =
+ | Closed_at of TimestampTypes.timestamp
+
+and issue = {
+ id : string;
+ number : int32;
+ title : string;
+ text : string;
+ url : string;
+ repository_prefix : string;
+ repository_fullname : string;
+ repository_shortname : string;
+ author : ChangeTypes.ident option;
+ created_at : TimestampTypes.timestamp option;
+ updated_at : TimestampTypes.timestamp option;
+ optional_closed_at : issue_optional_closed_at;
+ state : string;
+}
+
+type issue_commented_event = {
+ comment : string;
+}
+
+type issue_event_type =
+ | Issue_created
+ | Issue_commented of issue_commented_event
+ | Issue_closed
+
+and issue_event = {
+ id : string;
+ created_at : TimestampTypes.timestamp option;
+ author : ChangeTypes.ident option;
+ repository_prefix : string;
+ repository_fullname : string;
+ repository_shortname : string;
+ number : int32;
+ url : string;
+ type_ : issue_event_type;
+}
+
+
+(** {2 Default values} *)
+
+val default_ident :
+ ?uid:string ->
+ ?muid:string ->
+ unit ->
+ ident
+(** [default_ident ()] is the default value for type [ident] *)
+
+val default_issue_optional_closed_at : unit -> issue_optional_closed_at
+(** [default_issue_optional_closed_at ()] is the default value for type [issue_optional_closed_at] *)
+
+val default_issue :
+ ?id:string ->
+ ?number:int32 ->
+ ?title:string ->
+ ?text:string ->
+ ?url:string ->
+ ?repository_prefix:string ->
+ ?repository_fullname:string ->
+ ?repository_shortname:string ->
+ ?author:ChangeTypes.ident option ->
+ ?created_at:TimestampTypes.timestamp option ->
+ ?updated_at:TimestampTypes.timestamp option ->
+ ?optional_closed_at:issue_optional_closed_at ->
+ ?state:string ->
+ unit ->
+ issue
+(** [default_issue ()] is the default value for type [issue] *)
+
+val default_issue_commented_event :
+ ?comment:string ->
+ unit ->
+ issue_commented_event
+(** [default_issue_commented_event ()] is the default value for type [issue_commented_event] *)
+
+val default_issue_event_type : unit -> issue_event_type
+(** [default_issue_event_type ()] is the default value for type [issue_event_type] *)
+
+val default_issue_event :
+ ?id:string ->
+ ?created_at:TimestampTypes.timestamp option ->
+ ?author:ChangeTypes.ident option ->
+ ?repository_prefix:string ->
+ ?repository_fullname:string ->
+ ?repository_shortname:string ->
+ ?number:int32 ->
+ ?url:string ->
+ ?type_:issue_event_type ->
+ unit ->
+ issue_event
+(** [default_issue_event ()] is the default value for type [issue_event] *)