공통 정의와 프로젝트 수정본을 나누는 합성 모듈

"""Independent in-memory example of catalog registration and project snapshots."""
from hashlib import sha256
from threading import RLock
import re

class DefinitionError(ValueError):pass

def label(value):
    if not isinstance(value,str) or not re.fullmatch(r'[A-Za-z0-9][A-Za-z0-9._-]{0,79}',value):raise DefinitionError('INVALID_LABEL')

def digest(source):
    if not isinstance(source,str) or not source.strip() or len(source)>64000:raise DefinitionError('INVALID_SOURCE')
    return sha256(source.encode('utf-8')).hexdigest()

class DefinitionStore:
    def __init__(self):
        self._lock=RLock()
        self._catalog={}
        self._projects={}

    def register(self,identifier,source):
        label(identifier);hash_=digest(source)
        with self._lock:
            if identifier in self._catalog:raise DefinitionError('ALREADY_REGISTERED')
            self._catalog[identifier]={'source':source,'hash':hash_}
            return hash_

    def update_catalog(self,identifier,source,expected_hash):
        label(identifier);hash_=digest(source)
        with self._lock:
            current=self._catalog.get(identifier)
            if not current:raise DefinitionError('CATALOG_NOT_FOUND')
            if current['hash']!=expected_hash:raise DefinitionError('CATALOG_CHANGED')
            self._catalog[identifier]={'source':source,'hash':hash_}
            return hash_

    def synchronize(self,project):
        label(project)
        with self._lock:
            local=self._projects.setdefault(project,{})
            created=[]
            for identifier,entry in self._catalog.items():
                if identifier in local:continue
                local[identifier]={**entry,'base_hash':entry['hash']}
                created.append(identifier)
            return created

    def _entry(self,project,identifier):
        label(project);label(identifier)
        entry=self._projects.get(project,{}).get(identifier)
        if not entry:raise DefinitionError('SNAPSHOT_NOT_FOUND')
        return entry

    def inspect(self,project,identifier):
        with self._lock:
            entry=self._entry(project,identifier)
            return {'project':project,'identifier':identifier,**entry,
                    'locally_modified':entry['hash']!=entry['base_hash'],
                    'executed_here':False}

    def edit(self,project,identifier,source,expected_hash):
        hash_=digest(source)
        with self._lock:
            entry=self._entry(project,identifier)
            if entry['hash']!=expected_hash:raise DefinitionError('SNAPSHOT_CHANGED')
            entry.update(source=source,hash=hash_)
            return self.inspect(project,identifier)

    def require_current(self,project,identifier,expected_hash):
        with self._lock:
            entry=self._entry(project,identifier)
            if entry['hash']!=expected_hash:raise DefinitionError('SNAPSHOT_CHANGED')
            return self.inspect(project,identifier)