bitx_hub
Local PR/Issue metadata + GitHub sync (extension module for mizchi/bit)
git
hub
pr
issue
moon add mizchi/bitx_hub@0.46.4
Download zipAuthor
Version
0.46.4
License
Apache-2.0
Repository
Last updated
4 days ago
Downloads
64
Dependencies
- mizchi/bit_core0.46.4
- mizchi/bit_object0.46.4
- mizchi/bit_repo0.46.4
- mizchi/bit_io0.46.4
- mizchi/bit_io_native0.46.4
- mizchi/bit_lib0.46.4
- mizchi/bit_types0.46.4
- mizchi/bit_pack0.46.4
- mizchi/bit_protocol0.46.4
- mizchi/x0.2.0
- moonbitlang/async0.19.4
- moonbitlang/x0.4.40
README#PrError
PR operation error
#ClaimAction
impl Show for ClaimAction
#ClaimMessage
pub struct ClaimMessage {
issue_id : String
action : ClaimAction
claimer : String
timestamp : Int64
} derive(Eq, Debug)impl Show for ClaimMessage#ClaimMessage::is_stale
Check if a claim is stale based on the threshold.
#ClaimMessage::new
fn ClaimMessage::new(issue_id : String, action : ClaimAction, claimer : String, timestamp : Int64) -> ClaimMessage#GhComment
pub struct GhComment {
id : Int
node_id : String
body : String
user : String
created_at : String
updated_at : String
}#GhIssue
#GhPullRequest
pub struct GhPullRequest {
number : Int
node_id : String
title : String
body : String
state : String
user : String
head_ref : String
head_repo : String
base_ref : String
labels : Array[String]
created_at : String
updated_at : String
merged : Bool
merged_at : String
}GitHub Pull Request from REST API
#GhPullRequest::from_json
#Hub
Hub manages Pull Requests and Issues stored in git notes
#Hub::add_comment
Add a comment to a Pull Request
#Hub::add_dep
Add a dependency relationship between two issues.
source_id is blocked by target_id.
Both issues are updated in separate put_record calls.
#Hub::add_issue_comment
fn Hub::add_issue_comment(self : Hub, objects : &ObjectStore, refs : &RefStore, clock : &Clock, issue_id : String, author : String, body : String, reply_to? : String?) -> IssueComment raise GitErrorAdd a comment to an Issue
#Hub::add_note
Add a note to a commit (Git compatible)
#Hub::add_note_plain
Add a plain note (Git standard, no metadata)
#Hub::broadcast_feature
Broadcast a feature completion notification (notify-only record)
#Hub::can_merge
fn Hub::can_merge(self : Hub, objects : &ObjectStore, refs : &RefStore, pr_id : String) -> Bool raise GitErrorCheck if a PR can be merged (no conflicts, PR is open)
#Hub::check_merge_policy
fn Hub::check_merge_policy(self : Hub, objects : &ObjectStore, refs : &RefStore, pr_id : String, policy : PrMergePolicy, signing_key? : String?) -> Unit raise GitError#Hub::close_issue
Close an Issue
#Hub::close_pr
Close a Pull Request
#Hub::create_issue
Create a new Issue
#Hub::create_pr
fn Hub::create_pr(self : Hub, objects : &ObjectStore, refs : &RefStore, clock : &Clock, title : String, body : String, source_branch : String, target_branch : String, author : String, source_repo? : String?, source_ref? : String?) -> PullRequest raise GitErrorCreate a new Pull Request
#Hub::delete_issue_comment
Delete a comment from an Issue
#Hub::find_canonical_node
Determine the canonical node from heartbeat records.
Returns the node_id of the most active node (highest vector clock, then highest commit count).
#Hub::find_sync_link_by_remote
fn Hub::find_sync_link_by_remote(self : Hub, objects : &ObjectStore, provider : String, repo : String, remote_number : Int) -> SyncLink?Find a SyncLink by provider, repo, and remote number
#Hub::get_issue
Get an Issue by ID
#Hub::get_note
Get a note for a commit
#Hub::get_pr
Get a Pull Request by ID
#Hub::get_sync_link
fn Hub::get_sync_link(self : Hub, objects : &ObjectStore, local_id : String, provider : String) -> SyncLink?Retrieve a SyncLink by local_id and provider
#Hub::get_work_item
#Hub::import_issues
fn Hub::import_issues(self : Hub, objects : &ObjectStore, refs : &RefStore, clock : &Clock, issues : Array[Issue]) -> ImportStats raise GitError#Hub::import_pr_proposals
fn Hub::import_pr_proposals(self : Hub, objects : &ObjectStore, refs : &RefStore, clock : &Clock, prs : Array[PullRequest]) -> ImportStats raise GitError#Hub::import_prs
fn Hub::import_prs(self : Hub, objects : &ObjectStore, refs : &RefStore, clock : &Clock, prs : Array[PullRequest]) -> ImportStats raise GitError#Hub::init
fn Hub::init(objects : &ObjectStore, refs : &RefStore, node_id? : String, signing_key? : String?, require_signed? : Bool) -> Hub raise GitErrorInitialize a new Hub
#Hub::is_approved
Check if a PR is approved (has at least one Approved review with no RequestChanges after it)
#Hub::link_issue
Link a cross-repo issue reference to an Issue
#Hub::link_pr_to_issue
Link a PR to an Issue
#Hub::list_comments
List comments for a Pull Request
#Hub::list_feature_broadcasts
List feature broadcast records
#Hub::list_issue_comments
fn Hub::list_issue_comments(self : Hub, objects : &ObjectStore, issue_id : String) -> Array[IssueComment]List comments for an Issue
#Hub::list_issues
List Issues, optionally filtered by state
#Hub::list_node_heartbeats
List all node heartbeats and determine which node is canonical.
The canonical node is the one with the highest vector clock.
#Hub::list_notes
List all notes in a ns
#Hub::list_pr_proposals
#Hub::list_pr_workflows
fn Hub::list_pr_workflows(self : Hub, objects : &ObjectStore, pr_id : String) -> Array[PrWorkflowResult]#Hub::list_prs
List Pull Requests, optionally filtered by state
#Hub::list_reviews
List reviews for a Pull Request
#Hub::list_sub_issues
fn Hub::list_sub_issues(self : Hub, objects : &ObjectStore, parent_id : String, state? : IssueState?) -> Array[Issue]List sub-issues of a parent issue
#Hub::list_sync_links
List all SyncLinks, optionally filtered by repo
#Hub::list_work_items
fn Hub::list_work_items(self : Hub, objects : &ObjectStore, state? : WorkItemState?, kind? : WorkItemKind?) -> Array[WorkItem]#Hub::load
fn Hub::load(objects : &ObjectStore, refs : &RefStore, node_id? : String, signing_key? : String?, require_signed? : Bool) -> Hub raise GitErrorLoad an existing Hub from git notes
#Hub::merge_pr
fn Hub::merge_pr(self : Hub, objects : &ObjectStore, refs : &RefStore, clock : &Clock, pr_id : String, merger : String, strategy? : PrMergeStrategy) -> PrMergeResult raise GitErrorMerge a Pull Request
#Hub::propose_pr
fn Hub::propose_pr(self : Hub, objects : &ObjectStore, refs : &RefStore, clock : &Clock, title : String, body : String, source_branch : String, target_branch : String, author : String, source_repo? : String?, source_ref? : String?, closes_issues? : Array[String]) -> PullRequest raise GitErrorCreate a PR proposal record (notify-only event stream)
#Hub::publish_node_heartbeat
Publish node heartbeat record for canonical node election.
Each node periodically publishes its metadata (commit count, last update time).
#Hub::put_sync_link
Store a SyncLink as a hub record
#Hub::record_pr_workflow
fn Hub::record_pr_workflow(self : Hub, objects : &ObjectStore, refs : &RefStore, clock : &Clock, pr_id : String, task : String, status : PrWorkflowStatus, workspace_fingerprint : String, author : String, txn_id? : String?, summary? : String) -> PrWorkflowResult raise GitError#Hub::reload_store
Reload store from current object/ref state
#Hub::remove_dep
Remove a dependency relationship between two issues.
source_id is no longer blocked by target_id.
#Hub::remove_note
Remove a note from a commit
#Hub::reopen_issue
Reopen a closed Issue
#Hub::reopen_pr
Reopen a closed Pull Request
#Hub::submit_review
fn Hub::submit_review(self : Hub, objects : &ObjectStore, refs : &RefStore, clock : &Clock, pr_id : String, author : String, verdict : ReviewVerdict, body : String, commit_id : ObjectId) -> PrReview raise GitErrorSubmit a review for a Pull Request
#Hub::update_issue
Update an Issue (title, body, labels, assignees)
#Hub::update_issue_comment
Update an existing comment on an Issue (replace body, keep id/timestamps)
#Hub::update_pr
fn Hub::update_pr(self : Hub, objects : &ObjectStore, refs : &RefStore, clock : &Clock, pr_id : String, title? : String?, body? : String?, labels? : Array[String]?) -> PullRequest raise GitErrorUpdate a Pull Request (title, body, labels)
#HubRecord
pub struct HubRecord {
version : Int
key : String
kind : String
clock : Map[String, Int64]
timestamp : Int64
node : String
deleted : Bool
signature : String?
payload : String
}#HubStore
#HubStore::delete_record
#HubStore::get_record
#HubStore::list_records
fn HubStore::list_records(self : HubStore, objects : &ObjectStore, prefix : String, include_deleted? : Bool) -> Array[HubRecord]#HubStore::load
fn HubStore::load(objects : &ObjectStore, refs : &RefStore, node_id? : String, signing_key? : String?, require_signed? : Bool) -> HubStore raise GitError#HubStore::put_record
#ImportStats
pub struct ImportStats {
created : Int
updated : Int
}#Issue
pub struct Issue {
id : String
title : String
body : String
author : String
created_at : Int64
updated_at : Int64
state : IssueState
labels : Array[String]
assignees : Array[String]
linked_prs : Array[String]
linked_issues : Array[String]
parent_id : String?
blocked_by : Array[String]
blocking : Array[String]
}Issue data
#Issue::new
fn Issue::new(id : String, title : String, body : String, author : String, created_at : Int64, updated_at : Int64, state : IssueState, labels? : Array[String], assignees? : Array[String], linked_prs? : Array[String], linked_issues? : Array[String], parent_id? : String?, blocked_by? : Array[String], blocking? : Array[String]) -> Issue#Issue::serialize
Serialize Issue to Git-style text format
#IssueComment
pub struct IssueComment {
id : String
issue_id : String
author : String
body : String
created_at : Int64
reply_to : String?
}Comment on an Issue
#IssueComment::new
fn IssueComment::new(id : String, issue_id : String, author : String, body : String, created_at : Int64, reply_to? : String?) -> IssueComment#IssueComment::serialize
Serialize IssueComment to Git-style text format
#IssueState
#NodeHeartbeat
pub struct NodeHeartbeat {
node_id : String
commit_count : Int
main_tip : String
timestamp : Int64
clock : Map[String, Int64]
}Node metadata extracted from heartbeat records
#Note
pub struct Note {
commit_id : ObjectId
body : String
author : String
created_at : Int64
ns : String
}Note attached to a commit (Git notes compatible)
#Note::new
#Note::serialize
Serialize Note to Git-style text format
Note: Git standard notes are plain text, but we add metadata for Hub
#PrComment
pub struct PrComment {
id : String
pr_id : String
author : String
body : String
created_at : Int64
reply_to : String?
file_path : String?
line_number : Int?
commit_id : ObjectId?
}Comment on a Pull Request
#PrComment::new
#PrMergePolicy
pub struct PrMergePolicy {
required_approvals : Int
allow_request_changes : Bool
require_signed_records : Bool
required_workflows : Array[String]
}#PrMergePolicy::allow_request_changes
#PrMergePolicy::new
fn PrMergePolicy::new(required_approvals : Int, allow_request_changes : Bool, require_signed_records : Bool, required_workflows? : Array[String]) -> PrMergePolicy#PrMergePolicy::require_signed_records
#PrMergePolicy::required_approvals
#PrMergePolicy::required_workflows
#PrMergeResult
#PrReview
pub struct PrReview {
id : String
pr_id : String
author : String
verdict : ReviewVerdict
body : String
created_at : Int64
commit_id : ObjectId
}Review on a Pull Request
#PrReview::new
fn PrReview::new(id : String, pr_id : String, author : String, verdict : ReviewVerdict, body : String, created_at : Int64, commit_id : ObjectId) -> PrReview#PrReview::serialize
Serialize PrReview to Git-style text format
#PrState
#PrSyncResult
#PrSyncResult::new
fn PrSyncResult::new(success : Bool, message : String, local_commit : ObjectId?, remote_commit : ObjectId?) -> PrSyncResult#PrWorkflowResult
pub struct PrWorkflowResult {
pr_id : String
task : String
status : PrWorkflowStatus
workspace_fingerprint : String
txn_id : String?
author : String
updated_at : Int64
summary : String
}#PrWorkflowResult::new
fn PrWorkflowResult::new(pr_id : String, task : String, status : PrWorkflowStatus, workspace_fingerprint : String, author : String, updated_at : Int64, txn_id? : String?, summary? : String) -> PrWorkflowResult#PrWorkflowResult::status
#PrWorkflowResult::updated_at
#PrWorkflowResult::workspace_fingerprint
#PrWorkflowStatus
impl Show for PrWorkflowStatus#PullRequest
pub struct PullRequest {
id : String
title : String
body : String
source_branch : String
source_repo : String?
source_ref : String?
source_commit : ObjectId
target_branch : String
target_commit : ObjectId
author : String
created_at : Int64
updated_at : Int64
state : PrState
labels : Array[String]
closes_issues : Array[String]
merge_commit : ObjectId?
}Pull Request data
#PullRequest::new
fn PullRequest::new(id : String, title : String, body : String, source_branch : String, source_commit : ObjectId, target_branch : String, target_commit : ObjectId, author : String, created_at : Int64, updated_at : Int64, state : PrState, labels : Array[String], closes_issues? : Array[String], merge_commit? : ObjectId?, source_repo? : String?, source_ref? : String?) -> PullRequest#PullRequest::serialize
Serialize PullRequest to Git-style text format
#RecordTriggerClass
impl Show for RecordTriggerClass#ReviewVerdict
Review verdict
impl Show for ReviewVerdict#SyncDiff
pub struct SyncDiff {
title_changed : Bool
body_changed : Bool
state_changed : Bool
labels_changed : Bool
assignees_changed : Bool
has_changes : Bool
}Describes what changed between a local Issue and a GitHub GhIssue
#SyncLink
pub struct SyncLink {
local_id : String
local_kind : String
provider : String
repo : String
remote_number : Int
remote_node_id : String
last_pull_at : Int64
last_push_at : Int64
remote_updated_at : Int64
}Tracks the mapping between a local bit work item and a remote GitHub issue/PR
#SyncLink::new
#WorkItem
pub struct WorkItem {
id : String
title : String
body : String
author : String
created_at : Int64
updated_at : Int64
state : WorkItemState
labels : Array[String]
assignees : Array[String]
linked_prs : Array[String]
linked_issues : Array[String]
patch : WorkItemPatch?
parent_id : String?
blocked_by : Array[String]
blocking : Array[String]
}Unified work item view of issue and pull request
#WorkItem::new
fn WorkItem::new(id : String, title : String, body : String, author : String, created_at : Int64, updated_at : Int64, state : WorkItemState, labels? : Array[String], assignees? : Array[String], linked_prs? : Array[String], linked_issues? : Array[String], patch? : WorkItemPatch?, parent_id? : String?, blocked_by? : Array[String], blocking? : Array[String]) -> WorkItem#WorkItem::serialize
Serialize WorkItem to Git-style text format
#WorkItemKind
Work item kind
impl Show for WorkItemKind#WorkItemPatch
Patch capability of a work item
#WorkItemPatch::closes_issues
#WorkItemPatch::new
fn WorkItemPatch::new(source_branch : String, source_commit : ObjectId, target_branch : String, target_commit : ObjectId, closes_issues? : Array[String], merge_commit? : ObjectId?, source_repo? : String?, source_ref? : String?) -> WorkItemPatch#WorkItemPatch::source_commit
#WorkItemPatch::target_commit
#WorkItemState
Unified state of an Issue/PullRequest work item
impl Show for WorkItemState#WorkItemState::to_issue_state
#compare_vector_clocks
Compare two vector clocks. Returns 1 if a > b, -1 if b > a, 0 if concurrent.
#find_remote_notes_ref
#find_upload_notes_ref
#gh_issue_to_issue
Convert a GitHub API issue to a local Issue
#gh_pr_to_pull_request
Convert a GitHub API pull request to a local PullRequest
#issue_diff_for_github
Compare a local Issue with a GitHub GhIssue and return a SyncDiff
#merge_notes_commits
fn merge_notes_commits(prs : Hub, fs : &FileSystem, git_dir : String, objects : &ObjectStore, refs : &RefStore, local_id : ObjectId, remote_id : ObjectId, conflict_policy? : RecordMergePolicy) -> PrSyncResult raise GitError#merge_record_bytes_with_policy
fn merge_record_bytes_with_policy(ours : Bytes, theirs : Bytes, conflict_policy : RecordMergePolicy) -> Bytes#parse_claims_from_envelopes
Parse claim messages from relay poll envelopes.
Each envelope has shape: { "payload": { ... }, "topic": "...", ... }
#parse_iso8601_to_unix
fn parse_iso8601_to_unix(iso_str : String) -> Int64Parse ISO 8601 timestamp string to Unix seconds.
Supports "YYYY-MM-DDThh:mm:ssZ" and "YYYY-MM-DDThh:mm:ss+00:00" formats.
Returns 0 for empty or unparseable strings.
#parse_issue_comment
Parse IssueComment from Git-style text format
#parse_legacy_issue
Parse legacy Issue payload (issue ...) from Git-style text format
#parse_legacy_pull_request
Parse legacy PullRequest payload (pr ...) from Git-style text format
#parse_note
Parse Note from Git-style text format (with metadata)
#parse_note_plain
Parse Note from plain text (Git compatible, creates minimal Note)
#parse_pr_comment
Parse PrComment from Git-style text format
#parse_pr_review
Parse PrReview from Git-style text format
#parse_pr_workflow_result
#parse_sync_link
Parse SyncLink from Git-style text format
#parse_work_item
Parse WorkItem from Git-style text format
#pr_diff_for_github
Compare a local PullRequest with a GitHub GhPullRequest and return a SyncDiff
#resolve_active_claims
Resolve active claims: for each issue_id, keep only the latest action.
If the latest action is Unclaim, the issue is not actively claimed.
#unix_to_iso8601
fn unix_to_iso8601(unix : Int64) -> StringConvert Unix seconds to ISO 8601 string in UTC ("YYYY-MM-DDThh:mm:ssZ").
#write_object_bytes
fn write_object_bytes(fs : &FileSystem, git_dir : String, id : ObjectId, compressed : Bytes) -> Unit raise GitErrorLocal PR/Issue metadata + GitHub sync (extension module for mizchi/bit)
githubprissue
0.46.4
Apache-2.0
Updated 4 days ago
64 downloadsDependencies
- mizchi/bit_core0.46.4
- mizchi/bit_object0.46.4
- mizchi/bit_repo0.46.4
- mizchi/bit_io0.46.4
- mizchi/bit_io_native0.46.4
- mizchi/bit_lib0.46.4
- mizchi/bit_types0.46.4
- mizchi/bit_pack0.46.4
- mizchi/bit_protocol0.46.4
- mizchi/x0.2.0
- moonbitlang/async0.19.4
- moonbitlang/x0.4.40