Compare commits
4 Commits
7a871e4e91
...
5895592786
Author | SHA1 | Date | |
---|---|---|---|
5895592786 | |||
f177286890 | |||
a576013073 | |||
9b329f3b8b |
@ -2,13 +2,24 @@
|
|||||||
Git snapshotting tool
|
Git snapshotting tool
|
||||||
"""
|
"""
|
||||||
from .lethe import (
|
from .lethe import (
|
||||||
snap, snap_ref, snap_tree, find_merge_base, deref_symref,
|
snap as snap,
|
||||||
update_ref, commit_tree, get_tree, get_commit, get_obj,
|
snap_ref as snap_ref,
|
||||||
shorten_hash, get_root, get_latest_commit,
|
snap_tree as snap_tree,
|
||||||
push_ref, fetch_ref,
|
find_merge_base as find_merge_base,
|
||||||
|
deref_symref as deref_symref,
|
||||||
|
update_ref as update_ref,
|
||||||
|
commit_tree as commit_tree,
|
||||||
|
get_tree as get_tree,
|
||||||
|
get_commit as get_commit,
|
||||||
|
get_obj as get_obj,
|
||||||
|
shorten_hash as shorten_hash,
|
||||||
|
get_root as get_root,
|
||||||
|
get_latest_commit as get_latest_commit,
|
||||||
|
push_ref as push_ref,
|
||||||
|
fetch_ref as fetch_ref,
|
||||||
)
|
)
|
||||||
|
|
||||||
from .endpoints import main
|
from .endpoints import main as main
|
||||||
|
|
||||||
__author__ = 'Jan Petykeiwicz'
|
__author__ = 'Jan Petykeiwicz'
|
||||||
__version__ = '0.13'
|
__version__ = '0.13'
|
||||||
|
119
lethe/lethe.py
119
lethe/lethe.py
@ -3,15 +3,14 @@
|
|||||||
Git snapshotting tool
|
Git snapshotting tool
|
||||||
"""
|
"""
|
||||||
|
|
||||||
from typing import Sequence, Union, Optional
|
from typing import Sequence
|
||||||
import subprocess
|
import subprocess
|
||||||
import tempfile
|
import tempfile
|
||||||
import datetime
|
import datetime
|
||||||
import argparse
|
|
||||||
from itertools import chain
|
from itertools import chain
|
||||||
|
|
||||||
|
|
||||||
def _run(command: Union[str, Sequence[str]], **kwargs) -> str:
|
def _run(command: str | Sequence[str], **kwargs) -> str:
|
||||||
"""
|
"""
|
||||||
Wrapper for `subprocess.run()`:
|
Wrapper for `subprocess.run()`:
|
||||||
|
|
||||||
@ -34,7 +33,7 @@ def _run(command: Union[str, Sequence[str]], **kwargs) -> str:
|
|||||||
return result.stdout.decode().strip()
|
return result.stdout.decode().strip()
|
||||||
|
|
||||||
|
|
||||||
def get_latest_commit(short: bool = True, cwd: Optional[str] = None) -> str:
|
def get_latest_commit(short: bool = True, cwd: str | None = None) -> str:
|
||||||
"""
|
"""
|
||||||
Get the most recent commit's hash.
|
Get the most recent commit's hash.
|
||||||
This includes non-lethe commits.
|
This includes non-lethe commits.
|
||||||
@ -43,14 +42,14 @@ def get_latest_commit(short: bool = True, cwd: Optional[str] = None) -> str:
|
|||||||
return _run(f'git log --all -1 --format=%{fmt}', cwd=cwd)
|
return _run(f'git log --all -1 --format=%{fmt}', cwd=cwd)
|
||||||
|
|
||||||
|
|
||||||
def shorten_hash(sha: str, cwd: Optional[str] = None) -> str:
|
def shorten_hash(sha: str, cwd: str | None = None) -> str:
|
||||||
"""
|
"""
|
||||||
Get the short version of a hash
|
Get the short version of a hash
|
||||||
"""
|
"""
|
||||||
return _run(f'git rev-parse --short {sha}', cwd=cwd)
|
return _run(f'git rev-parse --short {sha}', cwd=cwd)
|
||||||
|
|
||||||
|
|
||||||
def get_root(cwd: Optional[str] = None) -> str:
|
def get_root(cwd: str | None = None) -> str:
|
||||||
"""
|
"""
|
||||||
Get the root directory of a git repository
|
Get the root directory of a git repository
|
||||||
"""
|
"""
|
||||||
@ -60,7 +59,7 @@ def get_root(cwd: Optional[str] = None) -> str:
|
|||||||
return root
|
return root
|
||||||
|
|
||||||
|
|
||||||
def get_obj(ref: str, cwd: Optional[str] = None) -> str:
|
def get_obj(ref: str, cwd: str | None = None) -> str:
|
||||||
"""
|
"""
|
||||||
Transform a ref into its corresponding hash using git-rev-parse
|
Transform a ref into its corresponding hash using git-rev-parse
|
||||||
"""
|
"""
|
||||||
@ -68,25 +67,26 @@ def get_obj(ref: str, cwd: Optional[str] = None) -> str:
|
|||||||
return sha
|
return sha
|
||||||
|
|
||||||
|
|
||||||
def get_commit(ref: str, cwd: Optional[str] = None) -> str:
|
def get_commit(ref: str, cwd: str | None = None) -> str:
|
||||||
"""
|
"""
|
||||||
Transform a ref to a commit into its corresponding hash using git-rev-parse
|
Transform a ref to a commit into its corresponding hash using git-rev-parse
|
||||||
"""
|
"""
|
||||||
return get_obj(ref, cwd=cwd)
|
return get_obj(ref, cwd=cwd)
|
||||||
|
|
||||||
|
|
||||||
def get_tree(ref: str, cwd: Optional[str] = None) -> str:
|
def get_tree(ref: str, cwd: str | None = None) -> str:
|
||||||
"""
|
"""
|
||||||
Take a ref to a commit, and return the hash of the tree it points to
|
Take a ref to a commit, and return the hash of the tree it points to
|
||||||
"""
|
"""
|
||||||
return get_obj(ref + ':', cwd=cwd)
|
return get_obj(ref + ':', cwd=cwd)
|
||||||
|
|
||||||
|
|
||||||
def commit_tree(tree: str,
|
def commit_tree(
|
||||||
parents: Sequence[str],
|
tree: str,
|
||||||
message: Optional[str] = None,
|
parents: Sequence[str],
|
||||||
cwd: Optional[str] = None,
|
message: str | None = None,
|
||||||
) -> str:
|
cwd: str | None = None,
|
||||||
|
) -> str:
|
||||||
"""
|
"""
|
||||||
Create a commit pointing to the given tree, with the specified parent commits and message.
|
Create a commit pointing to the given tree, with the specified parent commits and message.
|
||||||
Return the hash of the created commit.
|
Return the hash of the created commit.
|
||||||
@ -99,13 +99,14 @@ def commit_tree(tree: str,
|
|||||||
return commit
|
return commit
|
||||||
|
|
||||||
|
|
||||||
def update_ref(target_ref: str,
|
def update_ref(
|
||||||
target_commit: str,
|
target_ref: str,
|
||||||
old_commit: Optional[str] = None,
|
target_commit: str,
|
||||||
*,
|
old_commit: str | None = None,
|
||||||
message: str = 'new snapshot',
|
*,
|
||||||
cwd: Optional[str] = None,
|
message: str = 'new snapshot',
|
||||||
) -> str:
|
cwd: str | None = None,
|
||||||
|
) -> str:
|
||||||
"""
|
"""
|
||||||
Update `target_ref` to point to `target_commit`, optionally verifying that
|
Update `target_ref` to point to `target_commit`, optionally verifying that
|
||||||
it points `old_commit` before the update.
|
it points `old_commit` before the update.
|
||||||
@ -118,12 +119,13 @@ def update_ref(target_ref: str,
|
|||||||
return result_ref
|
return result_ref
|
||||||
|
|
||||||
|
|
||||||
def push_ref(remote: str = 'origin',
|
def push_ref(
|
||||||
target_ref: str = 'refs/lethe/LATEST',
|
remote: str = 'origin',
|
||||||
remote_ref: Optional[str] = None,
|
target_ref: str = 'refs/lethe/LATEST',
|
||||||
*,
|
remote_ref: str | None = None,
|
||||||
cwd: Optional[str] = None,
|
*,
|
||||||
) -> str:
|
cwd: str | None = None,
|
||||||
|
) -> str:
|
||||||
"""
|
"""
|
||||||
Push `target_ref` to `remote` as `remote_ref`.
|
Push `target_ref` to `remote` as `remote_ref`.
|
||||||
By default, `remote_ref` will be the same as `target_ref`.
|
By default, `remote_ref` will be the same as `target_ref`.
|
||||||
@ -142,12 +144,13 @@ def push_ref(remote: str = 'origin',
|
|||||||
return _run(['git', 'push', '--force', remote, target_ref + ':' + remote_ref], cwd=cwd)
|
return _run(['git', 'push', '--force', remote, target_ref + ':' + remote_ref], cwd=cwd)
|
||||||
|
|
||||||
|
|
||||||
def fetch_ref(remote: str = 'origin',
|
def fetch_ref(
|
||||||
remote_ref: str = 'refs/lethe/LATEST',
|
remote: str = 'origin',
|
||||||
target_ref: Optional[str] = None,
|
remote_ref: str = 'refs/lethe/LATEST',
|
||||||
*,
|
target_ref: str | None = None,
|
||||||
cwd: Optional[str] = None,
|
*,
|
||||||
) -> str:
|
cwd: str | None = None,
|
||||||
|
) -> str:
|
||||||
"""
|
"""
|
||||||
Fetch `remote_ref` from `remote` as `target_ref`.
|
Fetch `remote_ref` from `remote` as `target_ref`.
|
||||||
By default, `target_ref` will be the same as `remote_ref`.
|
By default, `target_ref` will be the same as `remote_ref`.
|
||||||
@ -166,20 +169,22 @@ def fetch_ref(remote: str = 'origin',
|
|||||||
return _run(['git', 'fetch', '--force', remote, remote_ref + ':' + target_ref], cwd=cwd)
|
return _run(['git', 'fetch', '--force', remote, remote_ref + ':' + target_ref], cwd=cwd)
|
||||||
|
|
||||||
|
|
||||||
def deref_symref(ref: str,
|
def deref_symref(
|
||||||
*,
|
ref: str,
|
||||||
cwd: Optional[str] = None,
|
*,
|
||||||
) -> str:
|
cwd: str | None = None,
|
||||||
|
) -> str:
|
||||||
"""
|
"""
|
||||||
Dereference a symbolic ref
|
Dereference a symbolic ref
|
||||||
"""
|
"""
|
||||||
return _run(['git', 'symbolic-ref', '--quiet', ref], cwd=cwd)
|
return _run(['git', 'symbolic-ref', '--quiet', ref], cwd=cwd)
|
||||||
|
|
||||||
|
|
||||||
def find_merge_base(commits: Sequence[str],
|
def find_merge_base(
|
||||||
*,
|
commits: Sequence[str],
|
||||||
cwd: Optional[str] = None,
|
*,
|
||||||
) -> str:
|
cwd: str | None = None,
|
||||||
|
) -> str:
|
||||||
"""
|
"""
|
||||||
Find the "best common ancestor" commit.
|
Find the "best common ancestor" commit.
|
||||||
|
|
||||||
@ -200,7 +205,7 @@ def find_merge_base(commits: Sequence[str],
|
|||||||
return base
|
return base
|
||||||
|
|
||||||
|
|
||||||
def snap_tree(*, cwd: Optional[str] = None) -> str:
|
def snap_tree(*, cwd: str | None = None) -> str:
|
||||||
"""
|
"""
|
||||||
Create a new tree, consisting of all non-ignored files in the repository.
|
Create a new tree, consisting of all non-ignored files in the repository.
|
||||||
Return the hash of the tree.
|
Return the hash of the tree.
|
||||||
@ -214,12 +219,13 @@ def snap_tree(*, cwd: Optional[str] = None) -> str:
|
|||||||
return tree
|
return tree
|
||||||
|
|
||||||
|
|
||||||
def snap_ref(parent_refs: Sequence[str],
|
def snap_ref(
|
||||||
target_refs: Sequence[str],
|
parent_refs: Sequence[str],
|
||||||
message: Optional[str] = None,
|
target_refs: Sequence[str],
|
||||||
*,
|
message: str | None = None,
|
||||||
cwd: Optional[str] = None,
|
*,
|
||||||
) -> str:
|
cwd: str | None = None,
|
||||||
|
) -> str:
|
||||||
"""
|
"""
|
||||||
`message` is used as the commit message.
|
`message` is used as the commit message.
|
||||||
"""
|
"""
|
||||||
@ -227,7 +233,7 @@ def snap_ref(parent_refs: Sequence[str],
|
|||||||
parent_commits = [c for c in [get_commit(p, cwd=cwd) for p in parent_refs] if c]
|
parent_commits = [c for c in [get_commit(p, cwd=cwd) for p in parent_refs] if c]
|
||||||
old_commits = [get_commit(t, cwd=cwd) for t in target_refs]
|
old_commits = [get_commit(t, cwd=cwd) for t in target_refs]
|
||||||
|
|
||||||
commit = commit_tree(new_tree, set(parent_commits), message, cwd=cwd)
|
commit = commit_tree(new_tree, list(set(parent_commits)), message, cwd=cwd)
|
||||||
|
|
||||||
for target_ref, old_commit in zip(target_refs, old_commits):
|
for target_ref, old_commit in zip(target_refs, old_commits):
|
||||||
# update ref to point to commit, or create new ref
|
# update ref to point to commit, or create new ref
|
||||||
@ -237,12 +243,13 @@ def snap_ref(parent_refs: Sequence[str],
|
|||||||
return commit
|
return commit
|
||||||
|
|
||||||
|
|
||||||
def snap(parent_refs: Optional[Sequence[str]] = None,
|
def snap(
|
||||||
target_refs: Optional[Sequence[str]] = None,
|
parent_refs: Sequence[str] | None = None,
|
||||||
message: Optional[str] = None,
|
target_refs: Sequence[str] | None = None,
|
||||||
*,
|
message: str | None = None,
|
||||||
cwd: Optional[str] = None,
|
*,
|
||||||
) -> str:
|
cwd: str | None = None,
|
||||||
|
) -> str:
|
||||||
"""
|
"""
|
||||||
Create a new commit, containing all non-ignored files.
|
Create a new commit, containing all non-ignored files.
|
||||||
|
|
||||||
@ -291,7 +298,7 @@ def snap(parent_refs: Optional[Sequence[str]] = None,
|
|||||||
old_base_commit = get_commit(target_base, cwd=cwd)
|
old_base_commit = get_commit(target_base, cwd=cwd)
|
||||||
if old_base_commit:
|
if old_base_commit:
|
||||||
print(f'Migrating {target_base} to new naming scheme ({target_base}/LEGACY)...')
|
print(f'Migrating {target_base} to new naming scheme ({target_base}/LEGACY)...')
|
||||||
print(f'You may also want to delete refs/lethe/HEAD with `git update-ref -d refs/lethe/HEAD`')
|
print('You may also want to delete refs/lethe/HEAD with `git update-ref -d refs/lethe/HEAD`')
|
||||||
_run('git update-ref -d ' + target_base)
|
_run('git update-ref -d ' + target_base)
|
||||||
update_ref(target_base + '/LEGACY', old_base_commit,
|
update_ref(target_base + '/LEGACY', old_base_commit,
|
||||||
message='last commit using old refs/lethe/branchname approach')
|
message='last commit using old refs/lethe/branchname approach')
|
||||||
|
@ -46,3 +46,37 @@ path = "lethe/__init__.py"
|
|||||||
lethe = "lethe.endpoints:main"
|
lethe = "lethe.endpoints:main"
|
||||||
lethe-push = "lethe.endpoints:push"
|
lethe-push = "lethe.endpoints:push"
|
||||||
lethe-fetch = "lethe.endpoints:fetch"
|
lethe-fetch = "lethe.endpoints:fetch"
|
||||||
|
|
||||||
|
|
||||||
|
[tool.ruff]
|
||||||
|
exclude = [
|
||||||
|
".git",
|
||||||
|
"dist",
|
||||||
|
]
|
||||||
|
line-length = 145
|
||||||
|
indent-width = 4
|
||||||
|
lint.dummy-variable-rgx = "^(_+|(_+[a-zA-Z0-9_]*[a-zA-Z0-9]+?))$"
|
||||||
|
lint.select = [
|
||||||
|
"NPY", "E", "F", "W", "B", "ANN", "UP", "SLOT", "SIM", "LOG",
|
||||||
|
"C4", "ISC", "PIE", "PT", "RET", "TCH", "PTH", "INT",
|
||||||
|
"ARG", "PL", "R", "TRY",
|
||||||
|
"G010", "G101", "G201", "G202",
|
||||||
|
"Q002", "Q003", "Q004",
|
||||||
|
]
|
||||||
|
lint.ignore = [
|
||||||
|
#"ANN001", # No annotation
|
||||||
|
"ANN002", # *args
|
||||||
|
"ANN003", # **kwargs
|
||||||
|
"ANN401", # Any
|
||||||
|
"ANN101", # self: Self
|
||||||
|
"SIM108", # single-line if / else assignment
|
||||||
|
"RET504", # x=y+z; return x
|
||||||
|
"PIE790", # unnecessary pass
|
||||||
|
"ISC003", # non-implicit string concatenation
|
||||||
|
"C408", # dict(x=y) instead of {'x': y}
|
||||||
|
"PLR09", # Too many xxx
|
||||||
|
"PLR2004", # magic number
|
||||||
|
"PLC0414", # import x as x
|
||||||
|
"TRY003", # Long exception message
|
||||||
|
]
|
||||||
|
|
||||||
|
Loading…
Reference in New Issue
Block a user