Xolo Domain Layer: Entities and Repository Contract

// Reactive streams
Stream<List<CollectionEntity>> watchRootCollections();
Stream<List<CollectionEntity>> watchSubCollections(int parentId);
Stream<List<CollectionEntity>> watchAllCollections();
Stream<List<SavedRequestEntity>> watchRequestsInCollection(int collectionId);
Stream<List<SavedRequestEntity>> watchUnclassifiedRequests();
Stream<List<SavedRequestEntity>> watchSavedRequests();

// Mutations
Future<int> createCollection({
  required String name,
  String? description,
  int? parentId,
  String? authType,
  String? authData,
});
Future<bool> updateCollection(
  int id,
  String name,
  String? description, {
  String? authType,
  String? authData,
});
Future<void> deleteCollection(int id);
Future<bool> moveRequest(int requestId, int? collectionId);
Future<bool> moveCollection(int collectionId, int? newParentId);

// Queries
Future<List<CollectionEntity>> getCollectionPath(int collectionId);
Future<CollectionEntity?> findCollectionByName(String name, int? parentId);
Future<List<CollectionEntity>> getCollectionsWithPlainAuthData();
Future<void> updateCollectionAuthDataById(int id, String? authData);

Future<int> createRequest({
  required String name,
  required String method,
  required String url,
  String? headersJson,
  String? paramsJson,
  String? body,
  int? collectionId,
  String? schemaJson,
});
Future<bool> softDeleteRequest(int id);
Future<bool> restoreRequest(int id);
Future<SavedRequestEntity?> findRequestInCollection({
  required int collectionId,
  required String method,
  required String url,
});
Future<int> updateRequestContent({
  required int id,
  required String name,
  String? headersJson,
  String? paramsJson,
  String? body,
  String? schemaJson,
});
Future<bool> updateRequestAssertions(int requestId, String? assertionsJson);
Future<List<SavedRequestEntity>> fetchRequestsInCollection(int collectionId);

Stream<List<HistoryEntryEntity>> watchRecentHistory(int? workspaceId);
Future<int> addHistoryItem({
  required String method,
  required String url,
  String? originalUrl,
  int? statusCode,
  int? durationMs,
  int? responseSize,
  int? workspaceId,
});
Future<HistoryEntryEntity?> getHistoryById(int id);
Future<int> clearHistory(int? workspaceId);
Future<void> clearAllHistory();
Future<void> deleteHistoryEntry(HistoryEntryEntity entry);
Future<int> restoreHistoryEntry(HistoryEntryEntity entry);

// Environments
Stream<List<EnvironmentEntity>> watchEnvironments(int? workspaceId);
Stream<int?> watchActiveEnvironmentId(int? workspaceId);
Future<int> createEnvironment(String name, int? workspaceId);
Future<void> setActiveEnvironment(int? envId, int? workspaceId);
Future<int> deleteEnvironment(int id);

// Variables
Stream<List<EnvVariableEntity>> watchResolvedVariables(
  int? workspaceId,
  int? environmentId,
);
Stream<List<EnvVariableEntity>> watchVariables(
  int? workspaceId,
  int? environmentId,
);
Future<int> upsertVariable({
  int? id,
  required String key,
  required String value,
  int? environmentId,
  int? workspaceId,
});
Future<int> deleteVariable(int id);

Future<int> createCollectionRun({
  required int collectionId,
  int? workspaceId,
  int? environmentId,
  required int totalSteps,
  bool stopOnFailure,
  String? runOptionsJson,
});
Future<void> finishCollectionRun({
  required int runId,
  required RunStatus status,
  required int passedSteps,
  required int failedSteps,
  required int skippedSteps,
  String? variablesSnapshotJson,
});
Future<void> insertRunStepResult({
  required int runId,
  required RunStepResultEntity step,
});
Stream<List<CollectionRunEntity>> watchCollectionRuns({int? workspaceId});
Future<CollectionRunEntity?> getCollectionRunById(int id);
Future<List<RunStepResultEntity>> getRunStepResults(int runId);

// Tree traversal helpers used by RunPlanBuilder
Future<List<CollectionEntity>> fetchSubCollections(int parentId);
Future<CollectionEntity?> getCollectionById(int id);

Future<void> wipeAllLocalData();