- Updated the client submodule to the latest commit for improved features and stability. - Introduced new quality violation reports for better code quality assessment, including checks for duplicates, test smells, and magic numbers. - Enhanced linting configurations and diagnostics across various files to ensure cleaner code and adherence to standards.
1190 lines
69 KiB
Plaintext
1190 lines
69 KiB
Plaintext
duplicate_function_bodies: 1
|
|
Duplicate function bodies found:
|
|
Locations: src/noteflow/application/services/export_service.py:42-47, src/noteflow/grpc/_mixins/meeting.py:77-82, src/noteflow/grpc/_mixins/diarization_job.py:37-42, src/noteflow/grpc/_mixins/entities.py:50-55, src/noteflow/grpc/_mixins/annotation.py:51-56, src/noteflow/grpc/_mixins/webhooks.py:56-61, src/noteflow/grpc/_mixins/preferences.py:43-48, src/noteflow/grpc/_mixins/project/_types.py:30-35
|
|
Preview: async def __aexit__( self, exc_type: type[BaseException] | None, exc_val: BaseException | None, exc_tb: object, ) -> None: ......
|
|
|
|
repeated_code_patterns: 171
|
|
Pattern repeated 3 times:
|
|
OAUTH_FIELD_REFRESH_TOKEN,
|
|
OAUTH_FIELD_SCOPE,
|
|
OAUTH_FIELD_TOKEN_TYPE,
|
|
)...
|
|
Sample locations: src/noteflow/domain/value_objects.py:13, src/noteflow/config/constants/__init__.py:108, src/noteflow/infrastructure/calendar/oauth_helpers.py:16
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
meeting_id: str,
|
|
dek: bytes,
|
|
wrapped_dek: bytes,...
|
|
Sample locations: src/noteflow/grpc/service.py:331, src/noteflow/infrastructure/audio/writer.py:87, src/noteflow/grpc/_mixins/protocols.py:161
|
|
|
|
Pattern repeated 3 times:
|
|
segment_id: int
|
|
text: str
|
|
start_time: float
|
|
end_time: float...
|
|
Sample locations: src/noteflow/grpc/_types.py:13, src/noteflow/domain/entities/segment.py:38, src/noteflow/grpc/_client_mixins/converters.py:15
|
|
|
|
Pattern repeated 5 times:
|
|
def record_simple(
|
|
self,
|
|
event_type: str,
|
|
metrics: UsageMetrics | None = None,...
|
|
Sample locations: src/noteflow/application/observability/ports.py:151, src/noteflow/application/observability/ports.py:176, src/noteflow/infrastructure/observability/usage.py:78, src/noteflow/infrastructure/observability/usage.py:197, src/noteflow/infrastructure/observability/usage.py:274
|
|
|
|
Pattern repeated 5 times:
|
|
self,
|
|
event_type: str,
|
|
metrics: UsageMetrics | None = None,
|
|
*,...
|
|
Sample locations: src/noteflow/application/observability/ports.py:152, src/noteflow/application/observability/ports.py:177, src/noteflow/infrastructure/observability/usage.py:79, src/noteflow/infrastructure/observability/usage.py:198, src/noteflow/infrastructure/observability/usage.py:275
|
|
|
|
Pattern repeated 5 times:
|
|
event_type: str,
|
|
metrics: UsageMetrics | None = None,
|
|
*,
|
|
context: UsageEventContext | None = None,...
|
|
Sample locations: src/noteflow/application/observability/ports.py:153, src/noteflow/application/observability/ports.py:178, src/noteflow/infrastructure/observability/usage.py:80, src/noteflow/infrastructure/observability/usage.py:199, src/noteflow/infrastructure/observability/usage.py:276
|
|
|
|
Pattern repeated 5 times:
|
|
metrics: UsageMetrics | None = None,
|
|
*,
|
|
context: UsageEventContext | None = None,
|
|
**attributes: obje...
|
|
Sample locations: src/noteflow/application/observability/ports.py:154, src/noteflow/application/observability/ports.py:179, src/noteflow/infrastructure/observability/usage.py:81, src/noteflow/infrastructure/observability/usage.py:200, src/noteflow/infrastructure/observability/usage.py:277
|
|
|
|
Pattern repeated 5 times:
|
|
*,
|
|
context: UsageEventContext | None = None,
|
|
**attributes: object,
|
|
) -> None:...
|
|
Sample locations: src/noteflow/application/observability/ports.py:155, src/noteflow/application/observability/ports.py:180, src/noteflow/infrastructure/observability/usage.py:82, src/noteflow/infrastructure/observability/usage.py:201, src/noteflow/infrastructure/observability/usage.py:278
|
|
|
|
Pattern repeated 3 times:
|
|
await uow.integrations.set_secrets(
|
|
integration_id=integration.id,
|
|
secrets=tokens.to_secrets_dict(),...
|
|
Sample locations: src/noteflow/application/services/calendar_service.py:198, src/noteflow/application/services/calendar_service.py:363, src/noteflow/application/services/auth_helpers.py:127
|
|
|
|
Pattern repeated 11 times:
|
|
async def __aexit__(
|
|
self,
|
|
exc_type: type[BaseException] | None,
|
|
exc_val: BaseException | None,...
|
|
Sample locations: src/noteflow/application/services/export_service.py:42, src/noteflow/domain/ports/unit_of_work.py:188, src/noteflow/infrastructure/persistence/unit_of_work.py:254, src/noteflow/infrastructure/persistence/memory/unit_of_work.py:188, src/noteflow/grpc/_mixins/meeting.py:77, src/noteflow/grpc/_mixins/diarization_job.py:37, src/noteflow/grpc/_mixins/entities.py:50, src/noteflow/grpc/_mixins/annotation.py:51, src/noteflow/grpc/_mixins/webhooks.py:56, src/noteflow/grpc/_mixins/preferences.py:43
|
|
|
|
Pattern repeated 11 times:
|
|
self,
|
|
exc_type: type[BaseException] | None,
|
|
exc_val: BaseException | None,
|
|
exc_tb: object,...
|
|
Sample locations: src/noteflow/application/services/export_service.py:43, src/noteflow/domain/ports/unit_of_work.py:189, src/noteflow/infrastructure/persistence/unit_of_work.py:255, src/noteflow/infrastructure/persistence/memory/unit_of_work.py:189, src/noteflow/grpc/_mixins/meeting.py:78, src/noteflow/grpc/_mixins/diarization_job.py:38, src/noteflow/grpc/_mixins/entities.py:51, src/noteflow/grpc/_mixins/annotation.py:52, src/noteflow/grpc/_mixins/webhooks.py:57, src/noteflow/grpc/_mixins/preferences.py:44
|
|
|
|
Pattern repeated 8 times:
|
|
exc_type: type[BaseException] | None,
|
|
exc_val: BaseException | None,
|
|
exc_tb: object,
|
|
) -> None: ......
|
|
Sample locations: src/noteflow/application/services/export_service.py:44, src/noteflow/grpc/_mixins/meeting.py:79, src/noteflow/grpc/_mixins/diarization_job.py:39, src/noteflow/grpc/_mixins/entities.py:52, src/noteflow/grpc/_mixins/annotation.py:53, src/noteflow/grpc/_mixins/webhooks.py:58, src/noteflow/grpc/_mixins/preferences.py:45, src/noteflow/grpc/_mixins/project/_types.py:32
|
|
|
|
Pattern repeated 4 times:
|
|
user_id: UUID,
|
|
limit: int = 50,
|
|
offset: int = 0,
|
|
) -> Sequence[Workspace]:...
|
|
Sample locations: src/noteflow/application/services/identity_service.py:263, src/noteflow/domain/ports/repositories/identity/_workspace.py:110, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:327, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:104
|
|
|
|
Pattern repeated 3 times:
|
|
limit: int = 50,
|
|
offset: int = 0,
|
|
) -> Sequence[Workspace]:
|
|
"""List workspaces a user is a member of...
|
|
Sample locations: src/noteflow/application/services/identity_service.py:264, src/noteflow/domain/ports/repositories/identity/_workspace.py:111, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:328
|
|
|
|
Pattern repeated 5 times:
|
|
integration = await uow.integrations.get_by_provider(
|
|
provider=provider,
|
|
integration_type=Integratio...
|
|
Sample locations: src/noteflow/application/services/auth_service.py:313, src/noteflow/application/services/auth_service.py:379, src/noteflow/application/services/auth_helpers.py:99, src/noteflow/application/services/auth_helpers.py:141, src/noteflow/grpc/_mixins/identity.py:26
|
|
|
|
Pattern repeated 3 times:
|
|
states=states,
|
|
limit=limit,
|
|
offset=offset,
|
|
sort_desc=sort_desc,...
|
|
Sample locations: src/noteflow/application/services/meeting_service.py:120, src/noteflow/infrastructure/persistence/memory/repositories/core.py:58, src/noteflow/grpc/_mixins/meeting.py:349
|
|
|
|
Pattern repeated 4 times:
|
|
self,
|
|
meeting_id: MeetingId,
|
|
include_words: bool = True,
|
|
) -> Sequence[Segment]:...
|
|
Sample locations: src/noteflow/application/services/meeting_service.py:272, src/noteflow/domain/ports/repositories/transcript.py:155, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:113, src/noteflow/infrastructure/persistence/memory/repositories/core.py:98
|
|
|
|
Pattern repeated 3 times:
|
|
meeting_id: MeetingId,
|
|
include_words: bool = True,
|
|
) -> Sequence[Segment]:
|
|
"""Get all segments for a...
|
|
Sample locations: src/noteflow/application/services/meeting_service.py:273, src/noteflow/domain/ports/repositories/transcript.py:156, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:114
|
|
|
|
Pattern repeated 4 times:
|
|
self,
|
|
query_embedding: list[float],
|
|
limit: int = 10,
|
|
meeting_id: MeetingId | None = None,...
|
|
Sample locations: src/noteflow/application/services/meeting_service.py:292, src/noteflow/domain/ports/repositories/transcript.py:171, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:137, src/noteflow/infrastructure/persistence/memory/repositories/core.py:106
|
|
|
|
Pattern repeated 4 times:
|
|
query_embedding: list[float],
|
|
limit: int = 10,
|
|
meeting_id: MeetingId | None = None,
|
|
) -> Sequence[tu...
|
|
Sample locations: src/noteflow/application/services/meeting_service.py:293, src/noteflow/domain/ports/repositories/transcript.py:172, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:138, src/noteflow/infrastructure/persistence/memory/repositories/core.py:107
|
|
|
|
Pattern repeated 3 times:
|
|
limit: int = 10,
|
|
meeting_id: MeetingId | None = None,
|
|
) -> Sequence[tuple[Segment, float]]:
|
|
"""Searc...
|
|
Sample locations: src/noteflow/application/services/meeting_service.py:294, src/noteflow/domain/ports/repositories/transcript.py:173, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:139
|
|
|
|
Pattern repeated 3 times:
|
|
Args:
|
|
query_embedding: Query embedding vector.
|
|
limit: Maximum number of results.
|
|
meeting_id: Optiona...
|
|
Sample locations: src/noteflow/application/services/meeting_service.py:299, src/noteflow/domain/ports/repositories/transcript.py:178, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:144
|
|
|
|
Pattern repeated 4 times:
|
|
self,
|
|
meeting_id: MeetingId,
|
|
start_time: float,
|
|
end_time: float,...
|
|
Sample locations: src/noteflow/application/services/meeting_service.py:433, src/noteflow/domain/ports/repositories/transcript.py:277, src/noteflow/infrastructure/persistence/repositories/annotation_repo.py:97, src/noteflow/infrastructure/persistence/memory/repositories/unsupported.py:55
|
|
|
|
Pattern repeated 3 times:
|
|
Args:
|
|
meeting_id: Meeting identifier.
|
|
start_time: Start of time range in seconds.
|
|
end_time: End of t...
|
|
Sample locations: src/noteflow/application/services/meeting_service.py:440, src/noteflow/domain/ports/repositories/transcript.py:284, src/noteflow/infrastructure/persistence/repositories/annotation_repo.py:104
|
|
|
|
Pattern repeated 3 times:
|
|
workspace_id: UUID,
|
|
include_archived: bool = False,
|
|
) -> int:
|
|
"""Count projects in a workspace....
|
|
Sample locations: src/noteflow/application/services/project_service/crud.py:297, src/noteflow/domain/ports/repositories/identity/_project.py:170, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:405
|
|
|
|
Pattern repeated 5 times:
|
|
project_id: UUID,
|
|
user_id: UUID,
|
|
role: ProjectRole,
|
|
) -> ProjectMembership | None:...
|
|
Sample locations: src/noteflow/application/services/project_service/members.py:25, src/noteflow/application/services/project_service/members.py:52, src/noteflow/domain/ports/repositories/identity/_membership.py:53, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:90, src/noteflow/infrastructure/persistence/memory/repositories/project.py:116
|
|
|
|
Pattern repeated 4 times:
|
|
project_id: UUID,
|
|
limit: int = 100,
|
|
offset: int = 0,
|
|
) -> Sequence[ProjectMembership]:...
|
|
Sample locations: src/noteflow/application/services/project_service/members.py:106, src/noteflow/domain/ports/repositories/identity/_membership.py:87, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:149, src/noteflow/infrastructure/persistence/memory/repositories/project.py:133
|
|
|
|
Pattern repeated 3 times:
|
|
project_id: UUID,
|
|
user_id: UUID,
|
|
) -> ProjectMembership | None:
|
|
"""Get a user's membership in a proj...
|
|
Sample locations: src/noteflow/application/services/project_service/members.py:129, src/noteflow/domain/ports/repositories/identity/_membership.py:19, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:43
|
|
|
|
Pattern repeated 4 times:
|
|
RULE_FIELD_APP_MATCH_PATTERNS,
|
|
RULE_FIELD_AUTO_START_ENABLED,
|
|
RULE_FIELD_CALENDAR_MATCH_PATTERNS,
|
|
RU...
|
|
Sample locations: src/noteflow/domain/rules/builtin.py:13, src/noteflow/config/constants/__init__.py:37, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:12, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:12
|
|
|
|
Pattern repeated 3 times:
|
|
now = utc_now()
|
|
return cls(
|
|
id=uuid4(),
|
|
workspace_id=workspace_id,...
|
|
Sample locations: src/noteflow/domain/entities/integration.py:70, src/noteflow/domain/auth/oidc.py:272, src/noteflow/domain/webhooks/events.py:110
|
|
|
|
Pattern repeated 3 times:
|
|
UserRepository,
|
|
WebhookRepository,
|
|
WorkspaceRepository,
|
|
)...
|
|
Sample locations: src/noteflow/domain/ports/unit_of_work.py:19, src/noteflow/domain/ports/__init__.py:22, src/noteflow/infrastructure/persistence/memory/unit_of_work.py:25
|
|
|
|
Pattern repeated 3 times:
|
|
exc_type: type[BaseException] | None,
|
|
exc_val: BaseException | None,
|
|
exc_tb: object,
|
|
) -> None:...
|
|
Sample locations: src/noteflow/domain/ports/unit_of_work.py:190, src/noteflow/infrastructure/persistence/unit_of_work.py:256, src/noteflow/infrastructure/persistence/memory/unit_of_work.py:190
|
|
|
|
Pattern repeated 3 times:
|
|
exc_val: BaseException | None,
|
|
exc_tb: object,
|
|
) -> None:
|
|
"""Exit the unit of work context....
|
|
Sample locations: src/noteflow/domain/ports/unit_of_work.py:191, src/noteflow/infrastructure/persistence/unit_of_work.py:257, src/noteflow/infrastructure/persistence/memory/unit_of_work.py:191
|
|
|
|
Pattern repeated 3 times:
|
|
async def list_events(
|
|
self,
|
|
access_token: str,
|
|
hours_ahead: int = 24,...
|
|
Sample locations: src/noteflow/domain/ports/calendar.py:135, src/noteflow/infrastructure/calendar/google_adapter.py:78, src/noteflow/infrastructure/calendar/outlook_adapter.py:122
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
access_token: str,
|
|
hours_ahead: int = 24,
|
|
limit: int = 20,...
|
|
Sample locations: src/noteflow/domain/ports/calendar.py:136, src/noteflow/infrastructure/calendar/google_adapter.py:79, src/noteflow/infrastructure/calendar/outlook_adapter.py:123
|
|
|
|
Pattern repeated 3 times:
|
|
access_token: str,
|
|
hours_ahead: int = 24,
|
|
limit: int = 20,
|
|
) -> list[CalendarEventInfo]:...
|
|
Sample locations: src/noteflow/domain/ports/calendar.py:137, src/noteflow/infrastructure/calendar/google_adapter.py:80, src/noteflow/infrastructure/calendar/outlook_adapter.py:124
|
|
|
|
Pattern repeated 7 times:
|
|
Returns:
|
|
True if deleted, False if not found.
|
|
"""
|
|
......
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:75, src/noteflow/domain/ports/repositories/transcript.py:314, src/noteflow/domain/ports/repositories/external.py:198, src/noteflow/domain/ports/repositories/background.py:204, src/noteflow/domain/ports/repositories/identity/_workspace.py:103, src/noteflow/domain/ports/repositories/identity/_project.py:143, src/noteflow/domain/ports/repositories/identity/_user.py:95
|
|
|
|
Pattern repeated 3 times:
|
|
async def list_all(
|
|
self,
|
|
**kwargs: Unpack[MeetingListKwargs],
|
|
) -> tuple[Sequence[Meeting], int]:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:80, src/noteflow/infrastructure/persistence/repositories/meeting_repo.py:123, src/noteflow/infrastructure/persistence/memory/repositories/core.py:44
|
|
|
|
Pattern repeated 3 times:
|
|
async def add_batch(
|
|
self,
|
|
meeting_id: MeetingId,
|
|
segments: Sequence[Segment],...
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:135, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:75, src/noteflow/infrastructure/persistence/memory/repositories/core.py:87
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
meeting_id: MeetingId,
|
|
segments: Sequence[Segment],
|
|
) -> Sequence[Segment]:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:136, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:76, src/noteflow/infrastructure/persistence/memory/repositories/core.py:88
|
|
|
|
Pattern repeated 3 times:
|
|
async def get_by_meeting(
|
|
self,
|
|
meeting_id: MeetingId,
|
|
include_words: bool = True,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:154, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:112, src/noteflow/infrastructure/persistence/memory/repositories/core.py:97
|
|
|
|
Pattern repeated 3 times:
|
|
async def search_semantic(
|
|
self,
|
|
query_embedding: list[float],
|
|
limit: int = 10,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:170, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:136, src/noteflow/infrastructure/persistence/memory/repositories/core.py:105
|
|
|
|
Pattern repeated 3 times:
|
|
async def update_embedding(
|
|
self,
|
|
segment_db_id: int,
|
|
embedding: list[float],...
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:188, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:178, src/noteflow/infrastructure/persistence/memory/repositories/core.py:114
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
segment_db_id: int,
|
|
embedding: list[float],
|
|
) -> None:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:189, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:179, src/noteflow/infrastructure/persistence/memory/repositories/core.py:115
|
|
|
|
Pattern repeated 3 times:
|
|
async def update_speaker(
|
|
self,
|
|
segment_db_id: int,
|
|
speaker_id: str | None,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:212, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:198, src/noteflow/infrastructure/persistence/memory/repositories/core.py:121
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
segment_db_id: int,
|
|
speaker_id: str | None,
|
|
speaker_confidence: float,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:213, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:199, src/noteflow/infrastructure/persistence/memory/repositories/core.py:122
|
|
|
|
Pattern repeated 3 times:
|
|
segment_db_id: int,
|
|
speaker_id: str | None,
|
|
speaker_confidence: float,
|
|
) -> None:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:214, src/noteflow/infrastructure/persistence/repositories/segment_repo.py:200, src/noteflow/infrastructure/persistence/memory/repositories/core.py:123
|
|
|
|
Pattern repeated 3 times:
|
|
async def get_by_time_range(
|
|
self,
|
|
meeting_id: MeetingId,
|
|
start_time: float,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:276, src/noteflow/infrastructure/persistence/repositories/annotation_repo.py:96, src/noteflow/infrastructure/persistence/memory/repositories/unsupported.py:54
|
|
|
|
Pattern repeated 3 times:
|
|
meeting_id: MeetingId,
|
|
start_time: float,
|
|
end_time: float,
|
|
) -> Sequence[Annotation]:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/transcript.py:278, src/noteflow/infrastructure/persistence/repositories/annotation_repo.py:98, src/noteflow/infrastructure/persistence/memory/repositories/unsupported.py:56
|
|
|
|
Pattern repeated 3 times:
|
|
async def update(
|
|
self,
|
|
entity_id: UUID,
|
|
text: str | None = None,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/external.py:104, src/noteflow/infrastructure/persistence/repositories/entity_repo.py:176, src/noteflow/infrastructure/persistence/memory/repositories/unsupported.py:199
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
entity_id: UUID,
|
|
text: str | None = None,
|
|
category: str | None = None,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/external.py:105, src/noteflow/infrastructure/persistence/repositories/entity_repo.py:177, src/noteflow/infrastructure/persistence/memory/repositories/unsupported.py:200
|
|
|
|
Pattern repeated 3 times:
|
|
entity_id: UUID,
|
|
text: str | None = None,
|
|
category: str | None = None,
|
|
) -> NamedEntity | None:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/external.py:106, src/noteflow/infrastructure/persistence/repositories/entity_repo.py:178, src/noteflow/infrastructure/persistence/memory/repositories/unsupported.py:201
|
|
|
|
Pattern repeated 3 times:
|
|
async def get_by_provider(
|
|
self,
|
|
provider: str,
|
|
integration_type: str | None = None,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/external.py:151, src/noteflow/infrastructure/persistence/repositories/integration_repo.py:58, src/noteflow/infrastructure/persistence/memory/repositories/integration.py:28
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
provider: str,
|
|
integration_type: str | None = None,
|
|
) -> Integration | None:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/external.py:152, src/noteflow/infrastructure/persistence/repositories/integration_repo.py:59, src/noteflow/infrastructure/persistence/memory/repositories/integration.py:29
|
|
|
|
Pattern repeated 3 times:
|
|
async def list_sync_runs(
|
|
self,
|
|
integration_id: UUID,
|
|
limit: int = 20,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/external.py:279, src/noteflow/infrastructure/persistence/repositories/integration_repo.py:317, src/noteflow/infrastructure/persistence/memory/repositories/integration.py:118
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
integration_id: UUID,
|
|
limit: int = 20,
|
|
offset: int = 0,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/external.py:280, src/noteflow/infrastructure/persistence/repositories/integration_repo.py:318, src/noteflow/infrastructure/persistence/memory/repositories/integration.py:119
|
|
|
|
Pattern repeated 3 times:
|
|
integration_id: UUID,
|
|
limit: int = 20,
|
|
offset: int = 0,
|
|
) -> tuple[Sequence[SyncRun], int]:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/external.py:281, src/noteflow/infrastructure/persistence/repositories/integration_repo.py:319, src/noteflow/infrastructure/persistence/memory/repositories/integration.py:120
|
|
|
|
Pattern repeated 3 times:
|
|
limit: int = 20,
|
|
offset: int = 0,
|
|
) -> tuple[Sequence[SyncRun], int]:
|
|
"""List sync runs for an integ...
|
|
Sample locations: src/noteflow/domain/ports/repositories/external.py:282, src/noteflow/infrastructure/persistence/repositories/integration_repo.py:320, src/noteflow/infrastructure/persistence/memory/repositories/integration.py:121
|
|
|
|
Pattern repeated 3 times:
|
|
async def delete_meeting_assets(
|
|
self,
|
|
meeting_id: MeetingId,
|
|
asset_path: str | None = None,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/asset.py:12, src/noteflow/infrastructure/persistence/repositories/asset_repo.py:24, src/noteflow/infrastructure/persistence/memory/repositories/core.py:160
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
meeting_id: MeetingId,
|
|
asset_path: str | None = None,
|
|
) -> None:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/asset.py:13, src/noteflow/infrastructure/persistence/repositories/asset_repo.py:25, src/noteflow/infrastructure/persistence/memory/repositories/core.py:161
|
|
|
|
Pattern repeated 3 times:
|
|
async def update_status(
|
|
self,
|
|
job_id: str,
|
|
status: int,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/background.py:60, src/noteflow/infrastructure/persistence/repositories/diarization_job_repo.py:132, src/noteflow/infrastructure/persistence/memory/repositories/unsupported.py:86
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
job_id: str,
|
|
status: int,
|
|
**kwargs: Unpack[DiarizationStatusKwargs],...
|
|
Sample locations: src/noteflow/domain/ports/repositories/background.py:61, src/noteflow/infrastructure/persistence/repositories/diarization_job_repo.py:133, src/noteflow/infrastructure/persistence/memory/repositories/unsupported.py:87
|
|
|
|
Pattern repeated 3 times:
|
|
job_id: str,
|
|
status: int,
|
|
**kwargs: Unpack[DiarizationStatusKwargs],
|
|
) -> bool:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/background.py:62, src/noteflow/infrastructure/persistence/repositories/diarization_job_repo.py:134, src/noteflow/infrastructure/persistence/memory/repositories/unsupported.py:88
|
|
|
|
Pattern repeated 3 times:
|
|
async def get_all_with_metadata(
|
|
self,
|
|
keys: Sequence[str] | None = None,
|
|
) -> list[PreferenceWithMe...
|
|
Sample locations: src/noteflow/domain/ports/repositories/background.py:209, src/noteflow/infrastructure/persistence/repositories/preferences_repo.py:124, src/noteflow/infrastructure/persistence/memory/repositories/unsupported.py:153
|
|
|
|
Pattern repeated 3 times:
|
|
async def create(
|
|
self,
|
|
workspace_id: UUID,
|
|
name: str,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:63, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:246, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:84
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
workspace_id: UUID,
|
|
name: str,
|
|
owner_id: UUID,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:64, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:247, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:85
|
|
|
|
Pattern repeated 3 times:
|
|
workspace_id: UUID,
|
|
name: str,
|
|
owner_id: UUID,
|
|
**kwargs: Unpack[WorkspaceCreateKwargs],...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:65, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:248, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:86
|
|
|
|
Pattern repeated 3 times:
|
|
name: str,
|
|
owner_id: UUID,
|
|
**kwargs: Unpack[WorkspaceCreateKwargs],
|
|
) -> Workspace:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:66, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:249, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:87
|
|
|
|
Pattern repeated 3 times:
|
|
async def list_for_user(
|
|
self,
|
|
user_id: UUID,
|
|
limit: int = 50,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:108, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:325, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:102
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
user_id: UUID,
|
|
limit: int = 50,
|
|
offset: int = 0,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:109, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:326, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:103
|
|
|
|
Pattern repeated 3 times:
|
|
async def get_membership(
|
|
self,
|
|
workspace_id: UUID,
|
|
user_id: UUID,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:126, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:355, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:111
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
workspace_id: UUID,
|
|
user_id: UUID,
|
|
) -> WorkspaceMembership | None:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:127, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:356, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:112
|
|
|
|
Pattern repeated 3 times:
|
|
async def add_member(
|
|
self,
|
|
workspace_id: UUID,
|
|
user_id: UUID,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:142, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:378, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:119
|
|
|
|
Pattern repeated 6 times:
|
|
self,
|
|
workspace_id: UUID,
|
|
user_id: UUID,
|
|
role: WorkspaceRole,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:143, src/noteflow/domain/ports/repositories/identity/_workspace.py:161, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:379, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:403, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:120, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:129
|
|
|
|
Pattern repeated 3 times:
|
|
workspace_id: UUID,
|
|
user_id: UUID,
|
|
role: WorkspaceRole,
|
|
) -> WorkspaceMembership:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:144, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:380, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:121
|
|
|
|
Pattern repeated 3 times:
|
|
async def update_member_role(
|
|
self,
|
|
workspace_id: UUID,
|
|
user_id: UUID,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:160, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:402, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:128
|
|
|
|
Pattern repeated 3 times:
|
|
workspace_id: UUID,
|
|
user_id: UUID,
|
|
role: WorkspaceRole,
|
|
) -> WorkspaceMembership | None:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:162, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:404, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:130
|
|
|
|
Pattern repeated 3 times:
|
|
async def remove_member(
|
|
self,
|
|
workspace_id: UUID,
|
|
user_id: UUID,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:178, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:433, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:137
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
workspace_id: UUID,
|
|
user_id: UUID,
|
|
) -> bool:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:179, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:434, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:138
|
|
|
|
Pattern repeated 3 times:
|
|
async def list_members(
|
|
self,
|
|
workspace_id: UUID,
|
|
limit: int = 100,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:194, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:461, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:145
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
workspace_id: UUID,
|
|
limit: int = 100,
|
|
offset: int = 0,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:195, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:462, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:146
|
|
|
|
Pattern repeated 3 times:
|
|
workspace_id: UUID,
|
|
limit: int = 100,
|
|
offset: int = 0,
|
|
) -> Sequence[WorkspaceMembership]:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:196, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:463, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:147
|
|
|
|
Pattern repeated 3 times:
|
|
Returns:
|
|
List of memberships.
|
|
"""
|
|
......
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_workspace.py:207, src/noteflow/domain/ports/repositories/identity/_membership.py:98, src/noteflow/domain/ports/repositories/identity/_membership.py:118
|
|
|
|
Pattern repeated 3 times:
|
|
async def get(
|
|
self,
|
|
project_id: UUID,
|
|
user_id: UUID,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:17, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:41, src/noteflow/infrastructure/persistence/memory/repositories/project.py:97
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
project_id: UUID,
|
|
user_id: UUID,
|
|
) -> ProjectMembership | None:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:18, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:42, src/noteflow/infrastructure/persistence/memory/repositories/project.py:98
|
|
|
|
Pattern repeated 3 times:
|
|
async def add(
|
|
self,
|
|
project_id: UUID,
|
|
user_id: UUID,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:33, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:64, src/noteflow/infrastructure/persistence/memory/repositories/project.py:105
|
|
|
|
Pattern repeated 6 times:
|
|
self,
|
|
project_id: UUID,
|
|
user_id: UUID,
|
|
role: ProjectRole,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:34, src/noteflow/domain/ports/repositories/identity/_membership.py:52, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:65, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:89, src/noteflow/infrastructure/persistence/memory/repositories/project.py:106, src/noteflow/infrastructure/persistence/memory/repositories/project.py:115
|
|
|
|
Pattern repeated 3 times:
|
|
project_id: UUID,
|
|
user_id: UUID,
|
|
role: ProjectRole,
|
|
) -> ProjectMembership:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:35, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:66, src/noteflow/infrastructure/persistence/memory/repositories/project.py:107
|
|
|
|
Pattern repeated 3 times:
|
|
async def update_role(
|
|
self,
|
|
project_id: UUID,
|
|
user_id: UUID,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:51, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:88, src/noteflow/infrastructure/persistence/memory/repositories/project.py:114
|
|
|
|
Pattern repeated 3 times:
|
|
async def remove(
|
|
self,
|
|
project_id: UUID,
|
|
user_id: UUID,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:69, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:119, src/noteflow/infrastructure/persistence/memory/repositories/project.py:123
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
project_id: UUID,
|
|
user_id: UUID,
|
|
) -> bool:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:70, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:120, src/noteflow/infrastructure/persistence/memory/repositories/project.py:124
|
|
|
|
Pattern repeated 3 times:
|
|
async def list_for_project(
|
|
self,
|
|
project_id: UUID,
|
|
limit: int = 100,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:85, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:147, src/noteflow/infrastructure/persistence/memory/repositories/project.py:131
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
project_id: UUID,
|
|
limit: int = 100,
|
|
offset: int = 0,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:86, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:148, src/noteflow/infrastructure/persistence/memory/repositories/project.py:132
|
|
|
|
Pattern repeated 3 times:
|
|
async def list_for_user(
|
|
self,
|
|
user_id: UUID,
|
|
workspace_id: UUID | None = None,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:103, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:173, src/noteflow/infrastructure/persistence/memory/repositories/project.py:140
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
user_id: UUID,
|
|
workspace_id: UUID | None = None,
|
|
limit: int = 100,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:104, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:174, src/noteflow/infrastructure/persistence/memory/repositories/project.py:141
|
|
|
|
Pattern repeated 3 times:
|
|
user_id: UUID,
|
|
workspace_id: UUID | None = None,
|
|
limit: int = 100,
|
|
offset: int = 0,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:105, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:175, src/noteflow/infrastructure/persistence/memory/repositories/project.py:142
|
|
|
|
Pattern repeated 3 times:
|
|
workspace_id: UUID | None = None,
|
|
limit: int = 100,
|
|
offset: int = 0,
|
|
) -> Sequence[ProjectMembership...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:106, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:176, src/noteflow/infrastructure/persistence/memory/repositories/project.py:143
|
|
|
|
Pattern repeated 3 times:
|
|
async def bulk_add(
|
|
self,
|
|
project_id: UUID,
|
|
memberships: Sequence[tuple[UUID, ProjectRole]],...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:123, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:223, src/noteflow/infrastructure/persistence/memory/repositories/project.py:150
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
project_id: UUID,
|
|
memberships: Sequence[tuple[UUID, ProjectRole]],
|
|
) -> Sequence[ProjectMember...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:124, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:224, src/noteflow/infrastructure/persistence/memory/repositories/project.py:151
|
|
|
|
Pattern repeated 3 times:
|
|
async def count_for_project(
|
|
self,
|
|
project_id: UUID,
|
|
) -> int:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_membership.py:139, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:252, src/noteflow/infrastructure/persistence/memory/repositories/project.py:158
|
|
|
|
Pattern repeated 3 times:
|
|
async def get_by_slug(
|
|
self,
|
|
workspace_id: UUID,
|
|
slug: str,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:48, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:209, src/noteflow/infrastructure/persistence/memory/repositories/project.py:31
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
workspace_id: UUID,
|
|
slug: str,
|
|
) -> Project | None:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:49, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:210, src/noteflow/infrastructure/persistence/memory/repositories/project.py:32
|
|
|
|
Pattern repeated 3 times:
|
|
async def get_default_for_workspace(
|
|
self,
|
|
workspace_id: UUID,
|
|
) -> Project | None:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:64, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:232, src/noteflow/infrastructure/persistence/memory/repositories/project.py:39
|
|
|
|
Pattern repeated 3 times:
|
|
async def create(
|
|
self,
|
|
project_id: UUID,
|
|
workspace_id: UUID,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:78, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:253, src/noteflow/infrastructure/persistence/memory/repositories/project.py:46
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
project_id: UUID,
|
|
workspace_id: UUID,
|
|
name: str,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:79, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:254, src/noteflow/infrastructure/persistence/memory/repositories/project.py:47
|
|
|
|
Pattern repeated 3 times:
|
|
project_id: UUID,
|
|
workspace_id: UUID,
|
|
name: str,
|
|
**kwargs: Unpack[ProjectCreateKwargs],...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:80, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:255, src/noteflow/infrastructure/persistence/memory/repositories/project.py:48
|
|
|
|
Pattern repeated 3 times:
|
|
workspace_id: UUID,
|
|
name: str,
|
|
**kwargs: Unpack[ProjectCreateKwargs],
|
|
) -> Project:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:81, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:256, src/noteflow/infrastructure/persistence/memory/repositories/project.py:49
|
|
|
|
Pattern repeated 3 times:
|
|
async def list_for_workspace(
|
|
self,
|
|
workspace_id: UUID,
|
|
include_archived: bool = False,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:148, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:371, src/noteflow/infrastructure/persistence/memory/repositories/project.py:72
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
workspace_id: UUID,
|
|
include_archived: bool = False,
|
|
limit: int = 50,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:149, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:372, src/noteflow/infrastructure/persistence/memory/repositories/project.py:73
|
|
|
|
Pattern repeated 3 times:
|
|
workspace_id: UUID,
|
|
include_archived: bool = False,
|
|
limit: int = 50,
|
|
offset: int = 0,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:150, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:373, src/noteflow/infrastructure/persistence/memory/repositories/project.py:74
|
|
|
|
Pattern repeated 3 times:
|
|
include_archived: bool = False,
|
|
limit: int = 50,
|
|
offset: int = 0,
|
|
) -> Sequence[Project]:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:151, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:374, src/noteflow/infrastructure/persistence/memory/repositories/project.py:75
|
|
|
|
Pattern repeated 3 times:
|
|
async def count_for_workspace(
|
|
self,
|
|
workspace_id: UUID,
|
|
include_archived: bool = False,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:168, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:403, src/noteflow/infrastructure/persistence/memory/repositories/project.py:82
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
workspace_id: UUID,
|
|
include_archived: bool = False,
|
|
) -> int:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_project.py:169, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:404, src/noteflow/infrastructure/persistence/memory/repositories/project.py:83
|
|
|
|
Pattern repeated 3 times:
|
|
async def create_default(
|
|
self,
|
|
user_id: UUID,
|
|
display_name: str,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_user.py:57, src/noteflow/infrastructure/persistence/repositories/identity/user_repo.py:115, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:48
|
|
|
|
Pattern repeated 3 times:
|
|
self,
|
|
user_id: UUID,
|
|
display_name: str,
|
|
email: str | None = None,...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_user.py:58, src/noteflow/infrastructure/persistence/repositories/identity/user_repo.py:116, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:49
|
|
|
|
Pattern repeated 3 times:
|
|
user_id: UUID,
|
|
display_name: str,
|
|
email: str | None = None,
|
|
) -> User:...
|
|
Sample locations: src/noteflow/domain/ports/repositories/identity/_user.py:59, src/noteflow/infrastructure/persistence/repositories/identity/user_repo.py:117, src/noteflow/infrastructure/persistence/memory/repositories/identity.py:50
|
|
|
|
Pattern repeated 3 times:
|
|
RULE_FIELD_EXPORT_RULES,
|
|
RULE_FIELD_INCLUDE_AUDIO,
|
|
RULE_FIELD_INCLUDE_TIMESTAMPS,
|
|
RULE_FIELD_TEMPLAT...
|
|
Sample locations: src/noteflow/config/constants/__init__.py:42, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:16, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:16
|
|
|
|
Pattern repeated 3 times:
|
|
RULE_FIELD_INCLUDE_AUDIO,
|
|
RULE_FIELD_INCLUDE_TIMESTAMPS,
|
|
RULE_FIELD_TEMPLATE_ID,
|
|
RULE_FIELD_TRIGGER_...
|
|
Sample locations: src/noteflow/config/constants/__init__.py:43, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:17, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:17
|
|
|
|
Pattern repeated 3 times:
|
|
from noteflow.infrastructure.persistence.models.integrations.webhook import (
|
|
WebhookConfigModel,
|
|
We...
|
|
Sample locations: src/noteflow/infrastructure/converters/webhook_converters.py:15, src/noteflow/infrastructure/persistence/repositories/webhook_repo.py:14, src/noteflow/infrastructure/persistence/models/integrations/__init__.py:11
|
|
|
|
Pattern repeated 4 times:
|
|
def export(
|
|
self,
|
|
meeting: Meeting,
|
|
segments: Sequence[Segment],...
|
|
Sample locations: src/noteflow/infrastructure/export/html.py:167, src/noteflow/infrastructure/export/markdown.py:41, src/noteflow/infrastructure/export/protocols.py:24, src/noteflow/infrastructure/export/pdf.py:165
|
|
|
|
Pattern repeated 3 times:
|
|
)
|
|
from noteflow.infrastructure.persistence.repositories._base import (
|
|
BaseRepository,
|
|
DeleteByIdMix...
|
|
Sample locations: src/noteflow/infrastructure/persistence/repositories/webhook_repo.py:17, src/noteflow/infrastructure/persistence/repositories/integration_repo.py:20, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:35
|
|
|
|
Pattern repeated 6 times:
|
|
from noteflow.infrastructure.persistence.repositories._base import (
|
|
BaseRepository,
|
|
DeleteByIdMixin...
|
|
Sample locations: src/noteflow/infrastructure/persistence/repositories/webhook_repo.py:18, src/noteflow/infrastructure/persistence/repositories/integration_repo.py:21, src/noteflow/infrastructure/persistence/repositories/entity_repo.py:15, src/noteflow/infrastructure/persistence/repositories/identity/user_repo.py:11, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:29, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:36
|
|
|
|
Pattern repeated 4 times:
|
|
BaseRepository,
|
|
DeleteByIdMixin,
|
|
GetByIdMixin,
|
|
)...
|
|
Sample locations: src/noteflow/infrastructure/persistence/repositories/webhook_repo.py:19, src/noteflow/infrastructure/persistence/repositories/integration_repo.py:22, src/noteflow/infrastructure/persistence/repositories/entity_repo.py:16, src/noteflow/infrastructure/persistence/repositories/identity/user_repo.py:12
|
|
|
|
Pattern repeated 3 times:
|
|
),
|
|
)
|
|
model = await self._execute_scalar(stmt)
|
|
return self._to_domain(model) if model else None...
|
|
Sample locations: src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:227, src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:248, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:59
|
|
|
|
Pattern repeated 4 times:
|
|
.limit(limit)
|
|
.offset(offset)
|
|
)
|
|
models = await self._execute_scalars(stmt)...
|
|
Sample locations: src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:397, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:167, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:349, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:481
|
|
|
|
Pattern repeated 3 times:
|
|
.offset(offset)
|
|
)
|
|
models = await self._execute_scalars(stmt)
|
|
return [self._to_domain(m) for m in mod...
|
|
Sample locations: src/noteflow/infrastructure/persistence/repositories/identity/project_repo.py:398, src/noteflow/infrastructure/persistence/repositories/identity/project_membership_repo.py:168, src/noteflow/infrastructure/persistence/repositories/identity/workspace_repo.py:350
|
|
|
|
Pattern repeated 9 times:
|
|
from datetime import datetime
|
|
from typing import TYPE_CHECKING
|
|
from uuid import UUID as PyUUID
|
|
from ...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:5, src/noteflow/infrastructure/persistence/models/core/annotation.py:5, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:5, src/noteflow/infrastructure/persistence/models/integrations/integration.py:5, src/noteflow/infrastructure/persistence/models/organization/task.py:5, src/noteflow/infrastructure/persistence/models/organization/tagging.py:5, src/noteflow/infrastructure/persistence/models/entities/speaker.py:5, src/noteflow/infrastructure/persistence/models/entities/named_entity.py:5, src/noteflow/infrastructure/persistence/models/identity/settings.py:5
|
|
|
|
Pattern repeated 13 times:
|
|
id: Mapped[PyUUID] = mapped_column(
|
|
UUID(as_uuid=True),
|
|
primary_key=True,
|
|
default=uuid4,...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:61, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:38, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:97, src/noteflow/infrastructure/persistence/models/integrations/integration.py:49, src/noteflow/infrastructure/persistence/models/integrations/integration.py:152, src/noteflow/infrastructure/persistence/models/integrations/integration.py:201, src/noteflow/infrastructure/persistence/models/integrations/integration.py:299, src/noteflow/infrastructure/persistence/models/observability/usage_event.py:28, src/noteflow/infrastructure/persistence/models/organization/task.py:39, src/noteflow/infrastructure/persistence/models/organization/tagging.py:34
|
|
|
|
Pattern repeated 13 times:
|
|
UUID(as_uuid=True),
|
|
primary_key=True,
|
|
default=uuid4,
|
|
)...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:62, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:39, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:98, src/noteflow/infrastructure/persistence/models/integrations/integration.py:50, src/noteflow/infrastructure/persistence/models/integrations/integration.py:153, src/noteflow/infrastructure/persistence/models/integrations/integration.py:202, src/noteflow/infrastructure/persistence/models/integrations/integration.py:300, src/noteflow/infrastructure/persistence/models/observability/usage_event.py:29, src/noteflow/infrastructure/persistence/models/organization/task.py:40, src/noteflow/infrastructure/persistence/models/organization/tagging.py:35
|
|
|
|
Pattern repeated 21 times:
|
|
created_at: Mapped[datetime] = mapped_column(
|
|
DateTime(timezone=True),
|
|
nullable=False,
|
|
default=utc_n...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:88, src/noteflow/infrastructure/persistence/models/core/meeting.py:220, src/noteflow/infrastructure/persistence/models/core/diarization.py:46, src/noteflow/infrastructure/persistence/models/core/diarization.py:94, src/noteflow/infrastructure/persistence/models/core/annotation.py:54, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:63, src/noteflow/infrastructure/persistence/models/integrations/integration.py:72, src/noteflow/infrastructure/persistence/models/integrations/integration.py:121, src/noteflow/infrastructure/persistence/models/integrations/integration.py:233, src/noteflow/infrastructure/persistence/models/integrations/integration.py:313
|
|
|
|
Pattern repeated 25 times:
|
|
DateTime(timezone=True),
|
|
nullable=False,
|
|
default=utc_now,
|
|
)...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:89, src/noteflow/infrastructure/persistence/models/core/meeting.py:221, src/noteflow/infrastructure/persistence/models/core/diarization.py:47, src/noteflow/infrastructure/persistence/models/core/diarization.py:95, src/noteflow/infrastructure/persistence/models/core/annotation.py:55, src/noteflow/infrastructure/persistence/models/core/summary.py:37, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:64, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:119, src/noteflow/infrastructure/persistence/models/integrations/integration.py:73, src/noteflow/infrastructure/persistence/models/integrations/integration.py:122
|
|
|
|
Pattern repeated 3 times:
|
|
DateTime(timezone=True),
|
|
nullable=True,
|
|
)
|
|
metadata_: Mapped[dict[str, object]] = mapped_column(...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:98, src/noteflow/infrastructure/persistence/models/organization/task.py:84, src/noteflow/infrastructure/persistence/models/identity/identity.py:217
|
|
|
|
Pattern repeated 3 times:
|
|
nullable=True,
|
|
)
|
|
metadata_: Mapped[dict[str, object]] = mapped_column(
|
|
"metadata",...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:99, src/noteflow/infrastructure/persistence/models/organization/task.py:85, src/noteflow/infrastructure/persistence/models/identity/identity.py:218
|
|
|
|
Pattern repeated 6 times:
|
|
)
|
|
metadata_: Mapped[dict[str, object]] = mapped_column(
|
|
"metadata",
|
|
JSONB,...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:100, src/noteflow/infrastructure/persistence/models/organization/task.py:86, src/noteflow/infrastructure/persistence/models/entities/speaker.py:60, src/noteflow/infrastructure/persistence/models/identity/identity.py:55, src/noteflow/infrastructure/persistence/models/identity/identity.py:120, src/noteflow/infrastructure/persistence/models/identity/identity.py:219
|
|
|
|
Pattern repeated 6 times:
|
|
metadata_: Mapped[dict[str, object]] = mapped_column(
|
|
"metadata",
|
|
JSONB,
|
|
nullable=False,...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:101, src/noteflow/infrastructure/persistence/models/organization/task.py:87, src/noteflow/infrastructure/persistence/models/entities/speaker.py:61, src/noteflow/infrastructure/persistence/models/identity/identity.py:56, src/noteflow/infrastructure/persistence/models/identity/identity.py:121, src/noteflow/infrastructure/persistence/models/identity/identity.py:220
|
|
|
|
Pattern repeated 6 times:
|
|
"metadata",
|
|
JSONB,
|
|
nullable=False,
|
|
default=dict,...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:102, src/noteflow/infrastructure/persistence/models/organization/task.py:88, src/noteflow/infrastructure/persistence/models/entities/speaker.py:62, src/noteflow/infrastructure/persistence/models/identity/identity.py:57, src/noteflow/infrastructure/persistence/models/identity/identity.py:122, src/noteflow/infrastructure/persistence/models/identity/identity.py:221
|
|
|
|
Pattern repeated 15 times:
|
|
JSONB,
|
|
nullable=False,
|
|
default=dict,
|
|
)...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:103, src/noteflow/infrastructure/persistence/models/core/summary.py:48, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:109, src/noteflow/infrastructure/persistence/models/integrations/integration.py:63, src/noteflow/infrastructure/persistence/models/integrations/integration.py:176, src/noteflow/infrastructure/persistence/models/integrations/integration.py:229, src/noteflow/infrastructure/persistence/models/observability/usage_event.py:109, src/noteflow/infrastructure/persistence/models/organization/task.py:89, src/noteflow/infrastructure/persistence/models/entities/speaker.py:63, src/noteflow/infrastructure/persistence/models/identity/settings.py:62
|
|
|
|
Pattern repeated 3 times:
|
|
id: Mapped[int] = mapped_column(Integer, primary_key=True, autoincrement=True)
|
|
meeting_id: Mapped[Py...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:200, src/noteflow/infrastructure/persistence/models/core/diarization.py:83, src/noteflow/infrastructure/persistence/models/core/summary.py:28
|
|
|
|
Pattern repeated 6 times:
|
|
meeting_id: Mapped[PyUUID] = mapped_column(
|
|
UUID(as_uuid=True),
|
|
ForeignKey("noteflow.meetings.id", o...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/meeting.py:201, src/noteflow/infrastructure/persistence/models/core/diarization.py:32, src/noteflow/infrastructure/persistence/models/core/diarization.py:84, src/noteflow/infrastructure/persistence/models/core/annotation.py:39, src/noteflow/infrastructure/persistence/models/core/summary.py:29, src/noteflow/infrastructure/persistence/models/entities/named_entity.py:42
|
|
|
|
Pattern repeated 3 times:
|
|
UUID(as_uuid=True),
|
|
ForeignKey("noteflow.meetings.id", ondelete="CASCADE"),
|
|
nullable=False,
|
|
index=Tr...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/diarization.py:33, src/noteflow/infrastructure/persistence/models/core/diarization.py:85, src/noteflow/infrastructure/persistence/models/core/annotation.py:40
|
|
|
|
Pattern repeated 3 times:
|
|
ForeignKey("noteflow.meetings.id", ondelete="CASCADE"),
|
|
nullable=False,
|
|
index=True,
|
|
)...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/diarization.py:34, src/noteflow/infrastructure/persistence/models/core/diarization.py:86, src/noteflow/infrastructure/persistence/models/core/annotation.py:41
|
|
|
|
Pattern repeated 12 times:
|
|
nullable=False,
|
|
default=utc_now,
|
|
)
|
|
updated_at: Mapped[datetime] = mapped_column(...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/diarization.py:48, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:65, src/noteflow/infrastructure/persistence/models/integrations/integration.py:74, src/noteflow/infrastructure/persistence/models/integrations/integration.py:123, src/noteflow/infrastructure/persistence/models/integrations/integration.py:235, src/noteflow/infrastructure/persistence/models/organization/task.py:74, src/noteflow/infrastructure/persistence/models/entities/speaker.py:52, src/noteflow/infrastructure/persistence/models/entities/named_entity.py:59, src/noteflow/infrastructure/persistence/models/identity/settings.py:68, src/noteflow/infrastructure/persistence/models/identity/identity.py:47
|
|
|
|
Pattern repeated 12 times:
|
|
default=utc_now,
|
|
)
|
|
updated_at: Mapped[datetime] = mapped_column(
|
|
DateTime(timezone=True),...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/diarization.py:49, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:66, src/noteflow/infrastructure/persistence/models/integrations/integration.py:75, src/noteflow/infrastructure/persistence/models/integrations/integration.py:124, src/noteflow/infrastructure/persistence/models/integrations/integration.py:236, src/noteflow/infrastructure/persistence/models/organization/task.py:75, src/noteflow/infrastructure/persistence/models/entities/speaker.py:53, src/noteflow/infrastructure/persistence/models/entities/named_entity.py:60, src/noteflow/infrastructure/persistence/models/identity/settings.py:69, src/noteflow/infrastructure/persistence/models/identity/identity.py:48
|
|
|
|
Pattern repeated 12 times:
|
|
)
|
|
updated_at: Mapped[datetime] = mapped_column(
|
|
DateTime(timezone=True),
|
|
nullable=False,...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/diarization.py:50, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:67, src/noteflow/infrastructure/persistence/models/integrations/integration.py:76, src/noteflow/infrastructure/persistence/models/integrations/integration.py:125, src/noteflow/infrastructure/persistence/models/integrations/integration.py:237, src/noteflow/infrastructure/persistence/models/organization/task.py:76, src/noteflow/infrastructure/persistence/models/entities/speaker.py:54, src/noteflow/infrastructure/persistence/models/entities/named_entity.py:61, src/noteflow/infrastructure/persistence/models/identity/settings.py:70, src/noteflow/infrastructure/persistence/models/identity/identity.py:49
|
|
|
|
Pattern repeated 13 times:
|
|
updated_at: Mapped[datetime] = mapped_column(
|
|
DateTime(timezone=True),
|
|
nullable=False,
|
|
default=utc_n...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/diarization.py:51, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:68, src/noteflow/infrastructure/persistence/models/integrations/integration.py:77, src/noteflow/infrastructure/persistence/models/integrations/integration.py:126, src/noteflow/infrastructure/persistence/models/integrations/integration.py:238, src/noteflow/infrastructure/persistence/models/organization/task.py:77, src/noteflow/infrastructure/persistence/models/entities/speaker.py:55, src/noteflow/infrastructure/persistence/models/entities/named_entity.py:62, src/noteflow/infrastructure/persistence/models/identity/settings.py:71, src/noteflow/infrastructure/persistence/models/identity/settings.py:96
|
|
|
|
Pattern repeated 13 times:
|
|
DateTime(timezone=True),
|
|
nullable=False,
|
|
default=utc_now,
|
|
onupdate=utc_now,...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/diarization.py:52, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:69, src/noteflow/infrastructure/persistence/models/integrations/integration.py:78, src/noteflow/infrastructure/persistence/models/integrations/integration.py:127, src/noteflow/infrastructure/persistence/models/integrations/integration.py:239, src/noteflow/infrastructure/persistence/models/organization/task.py:78, src/noteflow/infrastructure/persistence/models/entities/speaker.py:56, src/noteflow/infrastructure/persistence/models/entities/named_entity.py:63, src/noteflow/infrastructure/persistence/models/identity/settings.py:72, src/noteflow/infrastructure/persistence/models/identity/settings.py:97
|
|
|
|
Pattern repeated 13 times:
|
|
nullable=False,
|
|
default=utc_now,
|
|
onupdate=utc_now,
|
|
)...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/diarization.py:53, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:70, src/noteflow/infrastructure/persistence/models/integrations/integration.py:79, src/noteflow/infrastructure/persistence/models/integrations/integration.py:128, src/noteflow/infrastructure/persistence/models/integrations/integration.py:240, src/noteflow/infrastructure/persistence/models/organization/task.py:79, src/noteflow/infrastructure/persistence/models/entities/speaker.py:57, src/noteflow/infrastructure/persistence/models/entities/named_entity.py:64, src/noteflow/infrastructure/persistence/models/identity/settings.py:73, src/noteflow/infrastructure/persistence/models/identity/settings.py:98
|
|
|
|
Pattern repeated 4 times:
|
|
segment_ids: Mapped[list[int]] = mapped_column(
|
|
ARRAY(Integer),
|
|
nullable=False,
|
|
server_default="{}",...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/annotation.py:49, src/noteflow/infrastructure/persistence/models/core/summary.py:89, src/noteflow/infrastructure/persistence/models/core/summary.py:121, src/noteflow/infrastructure/persistence/models/entities/named_entity.py:50
|
|
|
|
Pattern repeated 4 times:
|
|
ARRAY(Integer),
|
|
nullable=False,
|
|
server_default="{}",
|
|
)...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/annotation.py:50, src/noteflow/infrastructure/persistence/models/core/summary.py:90, src/noteflow/infrastructure/persistence/models/core/summary.py:122, src/noteflow/infrastructure/persistence/models/entities/named_entity.py:51
|
|
|
|
Pattern repeated 7 times:
|
|
)
|
|
created_at: Mapped[datetime] = mapped_column(
|
|
DateTime(timezone=True),
|
|
nullable=False,...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/core/annotation.py:53, src/noteflow/infrastructure/persistence/models/integrations/webhook.py:62, src/noteflow/infrastructure/persistence/models/integrations/integration.py:232, src/noteflow/infrastructure/persistence/models/entities/speaker.py:100, src/noteflow/infrastructure/persistence/models/identity/settings.py:65, src/noteflow/infrastructure/persistence/models/identity/identity.py:44, src/noteflow/infrastructure/persistence/models/identity/identity.py:204
|
|
|
|
Pattern repeated 5 times:
|
|
primary_key=True,
|
|
default=uuid4,
|
|
)
|
|
workspace_id: Mapped[PyUUID] = mapped_column(...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/integrations/webhook.py:40, src/noteflow/infrastructure/persistence/models/integrations/integration.py:51, src/noteflow/infrastructure/persistence/models/organization/task.py:41, src/noteflow/infrastructure/persistence/models/organization/tagging.py:36, src/noteflow/infrastructure/persistence/models/entities/speaker.py:40
|
|
|
|
Pattern repeated 5 times:
|
|
default=uuid4,
|
|
)
|
|
workspace_id: Mapped[PyUUID] = mapped_column(
|
|
UUID(as_uuid=True),...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/integrations/webhook.py:41, src/noteflow/infrastructure/persistence/models/integrations/integration.py:52, src/noteflow/infrastructure/persistence/models/organization/task.py:42, src/noteflow/infrastructure/persistence/models/organization/tagging.py:37, src/noteflow/infrastructure/persistence/models/entities/speaker.py:41
|
|
|
|
Pattern repeated 5 times:
|
|
)
|
|
workspace_id: Mapped[PyUUID] = mapped_column(
|
|
UUID(as_uuid=True),
|
|
ForeignKey("noteflow.workspaces....
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/integrations/webhook.py:42, src/noteflow/infrastructure/persistence/models/integrations/integration.py:53, src/noteflow/infrastructure/persistence/models/organization/task.py:43, src/noteflow/infrastructure/persistence/models/organization/tagging.py:38, src/noteflow/infrastructure/persistence/models/entities/speaker.py:42
|
|
|
|
Pattern repeated 6 times:
|
|
workspace_id: Mapped[PyUUID] = mapped_column(
|
|
UUID(as_uuid=True),
|
|
ForeignKey("noteflow.workspaces.id...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/integrations/webhook.py:43, src/noteflow/infrastructure/persistence/models/integrations/integration.py:54, src/noteflow/infrastructure/persistence/models/organization/task.py:44, src/noteflow/infrastructure/persistence/models/organization/tagging.py:39, src/noteflow/infrastructure/persistence/models/entities/speaker.py:43, src/noteflow/infrastructure/persistence/models/identity/identity.py:191
|
|
|
|
Pattern repeated 5 times:
|
|
UUID(as_uuid=True),
|
|
ForeignKey("noteflow.workspaces.id", ondelete="CASCADE"),
|
|
nullable=False,
|
|
)...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/integrations/webhook.py:44, src/noteflow/infrastructure/persistence/models/integrations/integration.py:55, src/noteflow/infrastructure/persistence/models/organization/tagging.py:40, src/noteflow/infrastructure/persistence/models/entities/speaker.py:44, src/noteflow/infrastructure/persistence/models/identity/identity.py:192
|
|
|
|
Pattern repeated 3 times:
|
|
if TYPE_CHECKING:
|
|
from noteflow.infrastructure.persistence.models.core.meeting import MeetingModel
|
|
f...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/integrations/integration.py:26, src/noteflow/infrastructure/persistence/models/organization/tagging.py:18, src/noteflow/infrastructure/persistence/models/entities/speaker.py:18
|
|
|
|
Pattern repeated 3 times:
|
|
from noteflow.infrastructure.persistence.models.core.meeting import MeetingModel
|
|
from noteflow.infra...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/integrations/integration.py:27, src/noteflow/infrastructure/persistence/models/organization/tagging.py:19, src/noteflow/infrastructure/persistence/models/entities/speaker.py:19
|
|
|
|
Pattern repeated 3 times:
|
|
ForeignKey("noteflow.workspaces.id", ondelete="CASCADE"),
|
|
nullable=False,
|
|
)
|
|
name: Mapped[str] = mapp...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/integrations/integration.py:56, src/noteflow/infrastructure/persistence/models/organization/tagging.py:41, src/noteflow/infrastructure/persistence/models/identity/identity.py:193
|
|
|
|
Pattern repeated 4 times:
|
|
nullable=False,
|
|
default=dict,
|
|
)
|
|
created_at: Mapped[datetime] = mapped_column(...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/integrations/integration.py:230, src/noteflow/infrastructure/persistence/models/identity/settings.py:63, src/noteflow/infrastructure/persistence/models/identity/identity.py:42, src/noteflow/infrastructure/persistence/models/identity/identity.py:202
|
|
|
|
Pattern repeated 4 times:
|
|
default=dict,
|
|
)
|
|
created_at: Mapped[datetime] = mapped_column(
|
|
DateTime(timezone=True),...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/integrations/integration.py:231, src/noteflow/infrastructure/persistence/models/identity/settings.py:64, src/noteflow/infrastructure/persistence/models/identity/identity.py:43, src/noteflow/infrastructure/persistence/models/identity/identity.py:203
|
|
|
|
Pattern repeated 3 times:
|
|
meeting_id: Mapped[PyUUID] = mapped_column(
|
|
UUID(as_uuid=True),
|
|
ForeignKey("noteflow.meetings.id", o...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/integrations/integration.py:263, src/noteflow/infrastructure/persistence/models/organization/tagging.py:70, src/noteflow/infrastructure/persistence/models/entities/speaker.py:89
|
|
|
|
Pattern repeated 3 times:
|
|
UUID(as_uuid=True),
|
|
ForeignKey("noteflow.meetings.id", ondelete="CASCADE"),
|
|
primary_key=True,
|
|
)...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/integrations/integration.py:264, src/noteflow/infrastructure/persistence/models/organization/tagging.py:71, src/noteflow/infrastructure/persistence/models/entities/speaker.py:90
|
|
|
|
Pattern repeated 3 times:
|
|
default=utc_now,
|
|
onupdate=utc_now,
|
|
)
|
|
metadata_: Mapped[dict[str, object]] = mapped_column(...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/entities/speaker.py:58, src/noteflow/infrastructure/persistence/models/identity/identity.py:53, src/noteflow/infrastructure/persistence/models/identity/identity.py:118
|
|
|
|
Pattern repeated 3 times:
|
|
onupdate=utc_now,
|
|
)
|
|
metadata_: Mapped[dict[str, object]] = mapped_column(
|
|
"metadata",...
|
|
Sample locations: src/noteflow/infrastructure/persistence/models/entities/speaker.py:59, src/noteflow/infrastructure/persistence/models/identity/identity.py:54, src/noteflow/infrastructure/persistence/models/identity/identity.py:119
|
|
|
|
Pattern repeated 4 times:
|
|
job_id: str,
|
|
job: DiarizationJob | None,
|
|
meeting_id: str | None,
|
|
) -> None:...
|
|
Sample locations: src/noteflow/grpc/_mixins/protocols.py:230, src/noteflow/grpc/_mixins/protocols.py:239, src/noteflow/grpc/_mixins/diarization/_status.py:60, src/noteflow/grpc/_mixins/diarization/_status.py:94
|
|
|
|
Pattern repeated 3 times:
|
|
repo: PreferencesRepositoryProvider,
|
|
request: noteflow_pb2.SetPreferencesRequest,
|
|
current_prefs: lis...
|
|
Sample locations: src/noteflow/grpc/_mixins/protocols.py:321, src/noteflow/grpc/_mixins/preferences.py:64, src/noteflow/grpc/_mixins/preferences.py:210
|
|
|
|
Pattern repeated 3 times:
|
|
meeting_id: str,
|
|
chunk: noteflow_pb2.AudioChunk,
|
|
context: GrpcContext,
|
|
) -> AsyncIterator[noteflow_p...
|
|
Sample locations: src/noteflow/grpc/_mixins/protocols.py:343, src/noteflow/grpc/_mixins/streaming/_mixin.py:143, src/noteflow/grpc/_mixins/streaming/_processing.py:35
|
|
|
|
Pattern repeated 3 times:
|
|
Args:
|
|
host: The servicer host.
|
|
meeting_id: Meeting identifier.
|
|
"""...
|
|
Sample locations: src/noteflow/grpc/_mixins/streaming/_cleanup.py:21, src/noteflow/grpc/_mixins/streaming/_cleanup.py:51, src/noteflow/grpc/_mixins/streaming/_partials.py:83
|
|
|
|
Pattern repeated 5 times:
|
|
)
|
|
await repo.commit()
|
|
log_state_transition(
|
|
"diarization_job",...
|
|
Sample locations: src/noteflow/grpc/_mixins/diarization/_jobs.py:216, src/noteflow/grpc/_mixins/diarization/_status.py:48, src/noteflow/grpc/_mixins/diarization/_status.py:82, src/noteflow/grpc/_mixins/diarization/_status.py:110, src/noteflow/grpc/_mixins/diarization/_status.py:139
|
|
|
|
Pattern repeated 5 times:
|
|
await repo.commit()
|
|
log_state_transition(
|
|
"diarization_job",
|
|
job_id,...
|
|
Sample locations: src/noteflow/grpc/_mixins/diarization/_jobs.py:217, src/noteflow/grpc/_mixins/diarization/_status.py:49, src/noteflow/grpc/_mixins/diarization/_status.py:83, src/noteflow/grpc/_mixins/diarization/_status.py:111, src/noteflow/grpc/_mixins/diarization/_status.py:140
|
|
|
|
Pattern repeated 5 times:
|
|
log_state_transition(
|
|
"diarization_job",
|
|
job_id,
|
|
_job_status_name(old_status),...
|
|
Sample locations: src/noteflow/grpc/_mixins/diarization/_jobs.py:218, src/noteflow/grpc/_mixins/diarization/_status.py:50, src/noteflow/grpc/_mixins/diarization/_status.py:84, src/noteflow/grpc/_mixins/diarization/_status.py:112, src/noteflow/grpc/_mixins/diarization/_status.py:141
|