// // DataAccessSyncTests.swift // PadelClubDataTests // // Created by Laurent Morvillier on 02/05/2025. // import Testing @testable import PadelClubData @testable import LeStorage struct SyncDataAccessTests { let username1: String = "UserDataTests" let password1: String = "MyPass1234--" let username2: String = "seconduser" let password2: String = "MyPass1234--" var storeCenterA: StoreCenter var storeCenterB: StoreCenter init() async throws { let conf = Config.server let dir = "storage" let dirA = "storageA" let dirB = "storageB" FileManager.default.deleteDirectoryInDocuments(directoryName: dir) FileManager.default.deleteDirectoryInDocuments(directoryName: dirA) FileManager.default.deleteDirectoryInDocuments(directoryName: dirB) self.storeCenterA = StoreCenter(directoryName: dirA) self.storeCenterB = StoreCenter(directoryName: dirB) // StoreCenter.main StoreCenter.main.configureURLs(secureScheme: conf.secure, domain: conf.domain, webSockets: false, useSynchronization: true) StoreCenter.main.tokenKeychain = MockKeychainStore(fileName: "\(dir)/token.json") StoreCenter.main.deviceKeychain = MockKeychainStore(fileName: "\(dir)/device.json") try StoreCenter.main.deviceKeychain.add(value: UUID().uuidString) StoreCenter.main.classProject = "PadelClubData" // if conf.inMemory { // try await self._createUsers() // } let token = try? StoreCenter.main.rawTokenShouldNotBeUsed() if token == nil { try await self.login(storeCenter: StoreCenter.main, username: self.username1, password: self.password1) } // StoreCenter A self.storeCenterA.configureURLs(secureScheme: conf.secure, domain: conf.domain, webSockets: false, useSynchronization: true) self.storeCenterA.tokenKeychain = MockKeychainStore(fileName: "\(dirA)/token.json") self.storeCenterA.deviceKeychain = MockKeychainStore(fileName: "\(dirA)/device.json") try self.storeCenterA.deviceKeychain.add(value: UUID().uuidString) self.storeCenterA.classProject = "PadelClubData" let tokenA = try? self.storeCenterA.rawTokenShouldNotBeUsed() if tokenA == nil { try await self.login(storeCenter: self.storeCenterA, username: self.username1, password: self.password1) } // StoreCenter B self.storeCenterB.configureURLs(secureScheme: conf.secure, domain: conf.domain, webSockets: false, useSynchronization: true) self.storeCenterB.tokenKeychain = MockKeychainStore(fileName: "\(dirB)/token.json") self.storeCenterB.deviceKeychain = MockKeychainStore(fileName: "\(dirB)/device.json") try self.storeCenterB.deviceKeychain.add(value: UUID().uuidString) self.storeCenterB.classProject = "PadelClubData" let tokenB = try? self.storeCenterB.rawTokenShouldNotBeUsed() if tokenB == nil { try await self.login(storeCenter: self.storeCenterB, username: self.username2, password: self.password2) } } fileprivate func _createUsers() async throws { let user1 = CustomUser(username: self.username1) let form1 = UserCreationForm(user: user1, username: self.username1, password: self.password1, firstName: "f", lastName: "l", email: "test1@lolomo.net", phone: "", country: "") let _: CustomUser = try await StoreCenter.main.service().createAccount(user: form1) let user2 = CustomUser(username: self.username2) let form2 = UserCreationForm(user: user2, username: self.username2, password: self.password2, firstName: "f2", lastName: "l2", email: "test2@lolomo.net", phone: "", country: "") let _: CustomUser = try await StoreCenter.main.service().createAccount(user: form2) } mutating func login(storeCenter: StoreCenter, username: String, password: String) async throws { let _: CustomUser = try await storeCenter.service().login(username: username, password: password) } @Test func testSetup() async throws { #expect(self.storeCenterA.isAuthenticated) #expect(self.storeCenterB.isAuthenticated) guard let userId1 = self.storeCenterA.userId else { throw TestError.notAuthenticated } guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } #expect(userId1 != userId2) } /// In this test, the first user: /// - creates an event and a tournament /// - shares the tournament with a second user /// - remove the sharing with the second user /// We test that the data is properly received and removed upon the sharing actions @Test func testTournamentSharing() async throws { guard let userId1 = self.storeCenterA.userId else { throw TestError.notAuthenticated } guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Setup let eventColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let tournamentColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let eventColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() let tournamentColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() var dataAccesses: [DataAccess] = try await self.storeCenterA.service().get() if let dataAccessCollection = self.storeCenterA.dataAccessCollection { try await dataAccessCollection.deleteAsync(contentOfs: dataAccesses) } else { Issue.record("dataAccessCollection should not be nil") } try await eventColA.deleteAsync(contentOfs: Array(eventColA)) try await tournamentColA.deleteAsync(contentOfs: Array(tournamentColA)) let _ = try await self.storeCenterB.testSynchronizeOnceAsync() #expect(eventColB.count == 0) #expect(tournamentColB.count == 0) // Create let eventA = Event(creator: userId1) try await eventColA.addOrUpdateAsync(instance: eventA) let tournamentA = Tournament(event: eventA.id, name: "P100") try await tournamentColA.addOrUpdateAsync(instance: tournamentA) // Share with user2 try await self.storeCenterA.setAuthorizedUsersAsync(for: tournamentA, users: [userId2]) var dataB = try await self.storeCenterB.testSynchronizeOnceAsync() var syncDataB = try SyncData(data: dataB, storeCenter: self.storeCenterB) #expect(syncDataB.shared.count == 1) // the tournament #expect(syncDataB.grants.count == 1) // the granted event #expect(eventColB.count == 1) #expect(eventColB.first?.sharing == .granted) #expect(tournamentColB.count == 1) #expect(tournamentColB.first?.sharing == .shared) // Remove sharing from user2 try await self.storeCenterA.setAuthorizedUsersAsync(for: tournamentA, users: []) dataB = try await self.storeCenterB.testSynchronizeOnceAsync() syncDataB = try SyncData(data: dataB, storeCenter: self.storeCenterB) #expect(syncDataB.revocations.count == 1) #expect(syncDataB.revocationParents.count == 1) #expect(eventColB.count == 0) #expect(tournamentColB.count == 0) dataAccesses = try await self.storeCenterA.service().get() #expect(dataAccesses.count == 0) } /// In this test, the first user: /// - creates a club and 2 events in that club /// - shares both events with a second user /// - removes the sharing of 1 event /// Here we want to test that the Club instance remains even if one event is removed from the second user @Test func testSharedRelationship() async throws { guard let userId1 = self.storeCenterA.userId else { throw TestError.notAuthenticated } guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Setup let eventColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let clubColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let eventColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() let clubColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() if let dataAccessCollection = self.storeCenterA.dataAccessCollection { try await dataAccessCollection.deleteAsync(contentOfs: Array(dataAccessCollection)) } try await eventColA.deleteAsync(contentOfs: Array(eventColA)) try await clubColA.deleteAsync(contentOfs: Array(clubColA)) let _ = try await self.storeCenterB.testSynchronizeOnceAsync() #expect(eventColB.count == 0) #expect(clubColB.count == 0) // Create let clubA = Club(creator: userId1, name: "Club A", acronym: "CA") try await clubColA.addOrUpdateAsync(instance: clubA) let event1A = Event(creator: userId1, club: clubA.id, name: "event 1") let event2A = Event(creator: userId1, club: clubA.id, name: "event 2") try await eventColA.addOrUpdateAsync(contentOfs: [event1A, event2A]) // Share with user2 try await self.storeCenterA.setAuthorizedUsersAsync(for: event1A, users: [userId2]) try await self.storeCenterA.setAuthorizedUsersAsync(for: event2A, users: [userId2]) var dataB = try await self.storeCenterB.testSynchronizeOnceAsync() var syncDataB = try SyncData(data: dataB, storeCenter: self.storeCenterB) #expect(syncDataB.shared.count == 1) #expect(syncDataB.grants.count == 1) let clubGrants = syncDataB.grants.first { $0.type == Club.self } let eventGrants = syncDataB.shared.first { $0.type == Event.self } #expect(clubGrants?.items.count == 1) #expect(eventGrants?.items.count == 2) #expect(eventColB.count == 2) #expect(clubColB.count == 1) // Remove sharing from user2 try await self.storeCenterA.setAuthorizedUsersAsync(for: event1A, users: []) dataB = try await self.storeCenterB.testSynchronizeOnceAsync() syncDataB = try SyncData(data: dataB, storeCenter: self.storeCenterB) #expect(syncDataB.revocations.count == 1) #expect(syncDataB.revocationParents.count == 1) #expect(eventColB.count == 1) #expect(clubColB.count == 1) // club remains because used in event2A } /// In this test, the first user: /// - creates one event and 2 clubs /// - shares the event with a second user /// - changes the club on the event /// Here we want to test that the first Club is removed and the second one is received @Test func testRelationshipChange() async throws { guard let userId1 = self.storeCenterA.userId else { throw TestError.notAuthenticated } guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Setup let eventColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let clubColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let eventColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() let clubColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() if let dataAccessCollection = self.storeCenterA.dataAccessCollection { try await dataAccessCollection.deleteAsync(contentOfs: Array(dataAccessCollection)) } try await eventColA.deleteAsync(contentOfs: Array(eventColA)) try await clubColA.deleteAsync(contentOfs: Array(clubColA)) let _ = try await self.storeCenterB.testSynchronizeOnceAsync() #expect(eventColB.count == 0) #expect(clubColB.count == 0) // Create let club1A = Club(creator: userId1, name: "Club 1", acronym: "C1") try await clubColA.addOrUpdateAsync(instance: club1A) let club2A = Club(creator: userId1, name: "Club 2", acronym: "C2") try await clubColA.addOrUpdateAsync(instance: club2A) let eventA = Event(creator: userId1, club: club1A.id, name: "event 1") try await eventColA.addOrUpdateAsync(instance: eventA) // Share with user2 try await self.storeCenterA.setAuthorizedUsersAsync(for: eventA, users: [userId2]) let _ = try await self.storeCenterB.testSynchronizeOnceAsync() #expect(eventColB.count == 1) #expect(clubColB.count == 1) // Change the club eventA.club = club2A.id try await eventColA.addOrUpdateAsync(instance: eventA) let dataB = try await self.storeCenterB.testSynchronizeOnceAsync() let syncDataB = try SyncData(data: dataB, storeCenter: self.storeCenterB) #expect(syncDataB.updates.count == 1) // event update #expect(syncDataB.sharedRelationshipSets.count == 1) #expect(syncDataB.sharedRelationshipRemovals.count == 1) print("club1A = \(club1A.id)") #expect(eventColB.first?.club == club2A.id) } /// In this test, the first user: /// - creates one event and 2 clubs /// - shares the event with a second user /// - changes the club on the event /// Here we want to test that the first Club is removed and the second one is received @Test func testRelationshipChangeFromSharedUser() async throws { guard let userId1 = self.storeCenterA.userId else { throw TestError.notAuthenticated } guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Setup let eventColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let clubColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let eventColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() let clubColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() if let dataAccessCollection = self.storeCenterA.dataAccessCollection { try await dataAccessCollection.deleteAsync(contentOfs: Array(dataAccessCollection)) } try await eventColA.deleteAsync(contentOfs: Array(eventColA)) try await clubColA.deleteAsync(contentOfs: Array(clubColA)) let _ = try await self.storeCenterB.testSynchronizeOnceAsync() #expect(eventColB.count == 0) #expect(clubColB.count == 0) let eventA = Event(creator: userId1, name: "event 1") try await eventColA.addOrUpdateAsync(instance: eventA) // Share with user2 try await self.storeCenterA.setAuthorizedUsersAsync(for: eventA, users: [userId2]) let _ = try await self.storeCenterB.testSynchronizeOnceAsync() #expect(eventColB.count == 1) let eventB = eventColB.first! // Create let club1B = Club(creator: userId2, name: "Club 1", acronym: "C1") try await clubColB.addOrUpdateAsync(instance: club1B) // Change the club eventB.club = club1B.id try await eventColB.addOrUpdateAsync(instance: eventB) let dataA = try await self.storeCenterA.testSynchronizeOnceAsync() print("club1A = \(club1B.id)") #expect(eventColA.first != nil) #expect(eventColA.first?.club == club1B.id) #expect(clubColA.first?.id == club1B.id) } /// In this test, the first user: /// - creates one event /// - shares the event with a second user /// The second user: /// - changes the club /// Here we want to test that the first Club is removed and the second one is received @Test func testRelationshipChangesByAgent() async throws { guard let userId1 = self.storeCenterA.userId else { throw TestError.notAuthenticated } guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Setup let eventColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let clubColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let courtsColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let eventColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() let clubColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() let courtsColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() if let dataAccessCollection = self.storeCenterA.dataAccessCollection { try await dataAccessCollection.deleteAsync(contentOfs: Array(dataAccessCollection)) } try await eventColA.deleteAsync(contentOfs: Array(eventColA)) try await clubColA.deleteAsync(contentOfs: Array(clubColA)) let _ = try await self.storeCenterB.testSynchronizeOnceAsync() #expect(eventColB.count == 0) #expect(clubColB.count == 0) // Create let clubA = Club(creator: userId1, name: "Club 1", acronym: "C1") try await clubColA.addOrUpdateAsync(instance: clubA) let eventA = Event(creator: userId1, club: clubA.id, name: "event 1") try await eventColA.addOrUpdateAsync(instance: eventA) let court1A = Court(index: 0, club: clubA.id) let court2A = Court(index: 1, club: clubA.id) try await courtsColA.addOrUpdateAsync(contentOfs: [court1A, court2A]) // Share with user2 try await self.storeCenterA.setAuthorizedUsersAsync(for: eventA, users: [userId2]) let _ = try await self.storeCenterB.testSynchronizeOnceAsync() guard let eventB = eventColB.first else { throw TestError.missingEvent } #expect(eventA.id == eventB.id) #expect(clubColB.count == 1) // Second user changes the club let club2B = Club(creator: userId2, name: "Club 2", acronym: "C2") try await clubColB.addOrUpdateAsync(instance: club2B) eventB.club = club2B.id try await eventColB.addOrUpdateAsync(instance: eventB) let data = try await self.storeCenterA.testSynchronizeOnceAsync() let syncData = try SyncData(data: data, storeCenter: self.storeCenterB) #expect(eventA.club == club2B.id) #expect(clubColB.count == 1) #expect(courtsColB.count == 0) } @Test func testBuildEverything() async throws { guard let _ = StoreCenter.main.userId else { throw TestError.notAuthenticated } guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Cleanup let tournamentColA: SyncedCollection = await StoreCenter.main.mainStore.asyncLoadingSynchronizedCollection() let tournamentColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() let tournamentsToDelete: [Tournament] = try await StoreCenter.main.service().get() try await tournamentColA.deleteAsync(contentOfs: tournamentsToDelete) // Setup tournament + build everything let tournament = Tournament() try await tournamentColA.addOrUpdateAsync(instance: tournament) try await tournament.deleteAndBuildEverythingAsync() let tourStoreA = try StoreCenter.main.store(identifier: tournament.id) let gsColA: SyncedCollection = try tourStoreA.syncedCollection() let roundColA: SyncedCollection = try tourStoreA.syncedCollection() let matchesColA: SyncedCollection = try tourStoreA.syncedCollection() #expect(gsColA.count == 4) #expect(roundColA.count == 15) #expect(matchesColA.count == 56) // todo add sharing try await StoreCenter.main.setAuthorizedUsersAsync(for: tournament, users: [userId2]) // Sync with 2nd store try await self.storeCenterB.testSynchronizeOnceAsync() #expect(tournamentColB.count == 1) let tourStoreB = try self.storeCenterB.store(identifier: tournament.id) let gsColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() let roundColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() let matchesColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() #expect(gsColB.count == 4) #expect(roundColB.count == 15) #expect(matchesColB.count == 56) // change setup + build everything tournament.groupStageCount = 2 tournament.teamCount = 20 try await tournamentColA.addOrUpdateAsync(instance: tournament) try await tournament.deleteAndBuildEverythingAsync() #expect(gsColA.count == 2) #expect(roundColA.count == 15) #expect(matchesColA.count == 44) // Sync with 2nd store let data = try await self.storeCenterB.testSynchronizeOnceAsync() let _ = try SyncData(data: data, storeCenter: self.storeCenterB) #expect(gsColB.count == 2) #expect(roundColB.count == 15) #expect(matchesColB.count == 44) } @Test func testBuildEverythingFromShared() async throws { guard let _ = StoreCenter.main.userId else { throw TestError.notAuthenticated } guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Cleanup let tournamentColA: SyncedCollection = await StoreCenter.main.mainStore.asyncLoadingSynchronizedCollection() let tournamentColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() let tournamentsToDelete: [Tournament] = try await StoreCenter.main.service().get() try await tournamentColA.deleteAsync(contentOfs: tournamentsToDelete) // Setup tournament + build everything let tournament = Tournament() try await tournamentColA.addOrUpdateAsync(instance: tournament) // todo add sharing try await StoreCenter.main.setAuthorizedUsersAsync(for: tournament, users: [userId2]) // Sync with 2nd store try await self.storeCenterB.testSynchronizeOnceAsync() #expect(tournamentColB.count == 1) let tournamentB = tournamentColB.first! try await tournamentB.deleteAndBuildEverythingAsync() #expect(tournamentColB.count == 1) // Sync with 2nd store let data = try await self.storeCenterA.testSynchronizeOnceAsync() let _ = try SyncData(data: data, storeCenter: self.storeCenterA) #expect(tournamentColA.count == 1) } @Test func testTournamentSharingTeamScoreIssue() async throws { guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Setup tournament let tournamentColA: SyncedCollection = await StoreCenter.main.mainStore.asyncLoadingSynchronizedCollection() let tournament = Tournament(name: "test_data_access_children") try await tournamentColA.addOrUpdateAsync(instance: tournament) let tourStoreA = try StoreCenter.main.store(identifier: tournament.id) let teamRegColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let playerRegColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let roundColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let matchColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let teamScoreColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let tr1 = TeamRegistration(tournament: tournament.id) let pr11 = PlayerRegistration(teamRegistration: tr1.id, firstName: "f1", lastName: "l1") let pr12 = PlayerRegistration(teamRegistration: tr1.id, firstName: "f2", lastName: "l2") let tr2 = TeamRegistration(tournament: tournament.id) let pr21 = PlayerRegistration(teamRegistration: tr2.id, firstName: "f21", lastName: "l21") let pr22 = PlayerRegistration(teamRegistration: tr2.id, firstName: "f22", lastName: "l22") try await teamRegColA.addOrUpdateAsync(contentOfs: [tr1, tr2]) try await playerRegColA.addOrUpdateAsync(contentOfs: [pr11, pr12, pr21, pr22]) let round = Round(tournament: tournament.id) let match = Match(round: round.id) let ts1 = TeamScore(match: match.id, team: tr1) let ts2 = TeamScore(match: match.id, team: tr2) try await roundColA.addOrUpdateAsync(instance: round) try await matchColA.addOrUpdateAsync(instance: match) try await teamScoreColA.addOrUpdateAsync(contentOfs: [ts1, ts2]) try await StoreCenter.main.setAuthorizedUsersAsync(for: tournament, users: [userId2]) let data = try await self.storeCenterB.testSynchronizeOnceAsync() let syncData = try SyncData(data: data, storeCenter: self.storeCenterB) #expect(syncData.shared.count == 1) let tournamentColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() #expect(tournamentColB.count == 1) let tourStoreB = try self.storeCenterB.store(identifier: tournament.id) let matchColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() let teamScoreColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() #expect(teamScoreColB.count == 2) let matchB = matchColB.first! matchB.courtIndex = 2 try await matchColB.addOrUpdateAsync(instance: matchB) #expect(teamScoreColB.count == 2) } @Test func testMatchSharingThenRevoking() async throws { guard let userId1 = StoreCenter.main.userId else { throw TestError.notAuthenticated } guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Setup tournament let tournamentColA: SyncedCollection = await StoreCenter.main.mainStore.asyncLoadingSynchronizedCollection() let eventColA: SyncedCollection = await StoreCenter.main.mainStore.asyncLoadingSynchronizedCollection() try await tournamentColA.deleteAsync(contentOfs: tournamentColA) let event = Event(creator: userId1) try await eventColA.addOrUpdateAsync(instance: event) let tournament = Tournament(event: event.id, name: "testMatchSharingThenTournamentDelete") try await tournamentColA.addOrUpdateAsync(instance: tournament) let tourStoreA = try StoreCenter.main.store(identifier: tournament.id) let teamRegColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let playerRegColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let roundColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let matchColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let teamScoreColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let tr1 = TeamRegistration(tournament: tournament.id) let pr11 = PlayerRegistration(teamRegistration: tr1.id, firstName: "f1", lastName: "l1") let pr12 = PlayerRegistration(teamRegistration: tr1.id, firstName: "f2", lastName: "l2") let tr2 = TeamRegistration(tournament: tournament.id) let pr21 = PlayerRegistration(teamRegistration: tr2.id, firstName: "f21", lastName: "l21") let pr22 = PlayerRegistration(teamRegistration: tr2.id, firstName: "f22", lastName: "l22") try await teamRegColA.addOrUpdateAsync(contentOfs: [tr1, tr2]) try await playerRegColA.addOrUpdateAsync(contentOfs: [pr11, pr12, pr21, pr22]) let round = Round(tournament: tournament.id) try await roundColA.addOrUpdateAsync(instance: round) let match = Match(round: round.id) try await matchColA.addOrUpdateAsync(instance: match) let ts1 = TeamScore(match: match.id, team: tr1) let ts2 = TeamScore(match: match.id, team: tr2) try await teamScoreColA.addOrUpdateAsync(contentOfs: [ts1, ts2]) try await StoreCenter.main.setAuthorizedUsersAsync(for: match, users: [userId2]) let data = try await self.storeCenterB.testSynchronizeOnceAsync() let syncData = try SyncData(data: data, storeCenter: self.storeCenterB) let tournamentColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() #expect(syncData.shared.count == 1) #expect(tournamentColB.count == 1) let tourStoreB = try self.storeCenterB.store(identifier: tournament.id) let matchColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() let playerRegColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() let teamRegColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() #expect(matchColB.count == 1) #expect(playerRegColB.count == 4) #expect(teamRegColB.count == 2) try await StoreCenter.main.setAuthorizedUsersAsync(for: match, users: []) let data2 = try await self.storeCenterB.testSynchronizeOnceAsync() let syncData2 = try SyncData(data: data2, storeCenter: self.storeCenterB) #expect(syncData2.revocations.count > 0) #expect(matchColB.count == 0) #expect(playerRegColB.count == 0) #expect(teamRegColB.count == 0) } @Test func testMatchSharingThenTournamentDelete() async throws { guard let userId1 = StoreCenter.main.userId else { throw TestError.notAuthenticated } guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Setup tournament let tournamentColA: SyncedCollection = await StoreCenter.main.mainStore.asyncLoadingSynchronizedCollection() let eventColA: SyncedCollection = await StoreCenter.main.mainStore.asyncLoadingSynchronizedCollection() try await tournamentColA.deleteAsync(contentOfs: tournamentColA) let event = Event(creator: userId1) try await eventColA.addOrUpdateAsync(instance: event) let tournament = Tournament(event: event.id, name: "testMatchSharingThenTournamentDelete") try await tournamentColA.addOrUpdateAsync(instance: tournament) let tourStoreA = try StoreCenter.main.store(identifier: tournament.id) let teamRegColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let playerRegColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let roundColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let matchColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let teamScoreColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let tr1 = TeamRegistration(tournament: tournament.id) let pr11 = PlayerRegistration(teamRegistration: tr1.id, firstName: "f1", lastName: "l1") let pr12 = PlayerRegistration(teamRegistration: tr1.id, firstName: "f2", lastName: "l2") let tr2 = TeamRegistration(tournament: tournament.id) let pr21 = PlayerRegistration(teamRegistration: tr2.id, firstName: "f21", lastName: "l21") let pr22 = PlayerRegistration(teamRegistration: tr2.id, firstName: "f22", lastName: "l22") try await teamRegColA.addOrUpdateAsync(contentOfs: [tr1, tr2]) try await playerRegColA.addOrUpdateAsync(contentOfs: [pr11, pr12, pr21, pr22]) let round = Round(tournament: tournament.id) try await roundColA.addOrUpdateAsync(instance: round) let match = Match(round: round.id) try await matchColA.addOrUpdateAsync(instance: match) let ts1 = TeamScore(match: match.id, team: tr1) let ts2 = TeamScore(match: match.id, team: tr2) try await teamScoreColA.addOrUpdateAsync(contentOfs: [ts1, ts2]) try await StoreCenter.main.setAuthorizedUsersAsync(for: match, users: [userId2]) let data = try await self.storeCenterB.testSynchronizeOnceAsync() let syncData = try SyncData(data: data, storeCenter: self.storeCenterB) let tournamentColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() #expect(syncData.shared.count == 1) #expect(tournamentColB.count == 1) let tourStoreB = try self.storeCenterB.store(identifier: tournament.id) let matchColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() let playerRegColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() let teamRegColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() let teamScoreColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() #expect(matchColB.count == 1) #expect(playerRegColB.count == 4) #expect(teamRegColB.count == 2) #expect(teamScoreColB.count == 2) try await roundColA.deleteAsync(instance: round) #expect(roundColA.count == 0) try await Task.sleep(nanoseconds: 1_000_000_000) // wait for cascading deletes to be finished let data2 = try await self.storeCenterB.testSynchronizeOnceAsync() let syncData2 = try SyncData(data: data2, storeCenter: self.storeCenterB) for deletion in syncData2.deletions { print(">>> deletion type = \(deletion.type), count = \(deletion.items.count)") } for revocation in syncData2.revocations { print(">>> revocation type = \(revocation.type), count = \(revocation.items.count)") } #expect(syncData2.deletions.count > 0) #expect(syncData2.revocations.count > 0) #expect(matchColB.count == 0) #expect(teamScoreColB.count == 0) // the delete of round deletes the match, which should revoke granted objects like player/teams #expect(playerRegColB.count == 0) #expect(teamRegColB.count == 0) } // needs to run on a postgreSQL, otherwise fails because of sqlite database locks @Test func testDataAccessForChildren() async throws { guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Setup tournament let tournamentColA: SyncedCollection = await StoreCenter.main.mainStore.asyncLoadingSynchronizedCollection() let tournamentColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() let tournament = Tournament(name: "test_data_access_children") try await tournamentColA.addOrUpdateAsync(instance: tournament) let tourStoreA = try StoreCenter.main.store(identifier: tournament.id) let teamRegColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() let playerRegColA: SyncedCollection = await tourStoreA.asyncLoadingSynchronizedCollection() // cleanup sync residues let _ = try await self.storeCenterB.testSynchronizeOnceAsync() try await StoreCenter.main.setAuthorizedUsersAsync(for: tournament, users: [userId2]) var teamRegistrations: [TeamRegistration] = [] var playerRegistrations: [PlayerRegistration] = [] let count = 5 for i in (0.. = await tourStoreB.asyncLoadingSynchronizedCollection() let playerRegColB: SyncedCollection = await tourStoreB.asyncLoadingSynchronizedCollection() #expect(tournamentColB.count == 1) #expect(teamRegColB.count == count) #expect(playerRegColB.count == count * 2) for team in teamRegistrations { try await teamRegColA.deleteAsync(instance: team) } try await Task.sleep(for: .milliseconds(100)) // without this, it looks like the sync date is smaller than the ModelLogs, so we don't get them all let data = try await self.storeCenterB.testSynchronizeOnceAsync() let syncData = try SyncData(data: data, storeCenter: self.storeCenterB) #expect(syncData.deletions.count == 2) let teamRegDeletions = syncData.deletions.first(where: { $0.type == TeamRegistration.self }) #expect(teamRegDeletions?.items.count == 5) let playerRegDeletions = syncData.deletions.first(where: { $0.type == PlayerRegistration.self }) #expect(playerRegDeletions?.items.count == 10) #expect(teamRegColB.count == 0) #expect(playerRegColB.count == 0) } /// In this test, the first user: /// - creates an event /// - shares the event with a second user /// - the second user creates a tournament on that event /// We test that the tournament related_user is the second user @Test func testRelatedUsers() async throws { guard let userId1 = StoreCenter.main.userId else { throw TestError.notAuthenticated } guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Setup let eventColA: SyncedCollection = await StoreCenter.main.mainStore.asyncLoadingSynchronizedCollection() let tournamentColA: SyncedCollection = await StoreCenter.main.mainStore.asyncLoadingSynchronizedCollection() let eventColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() let tournamentColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() if let dataAccessCollection = StoreCenter.main.dataAccessCollection { try await dataAccessCollection.deleteAsync(contentOfs: Array(dataAccessCollection)) } try await eventColA.deleteAsync(contentOfs: Array(eventColA)) try await tournamentColA.deleteAsync(contentOfs: Array(tournamentColA)) let _ = try await self.storeCenterB.testSynchronizeOnceAsync() #expect(eventColB.count == 0) #expect(tournamentColB.count == 0) // Create let eventA = Event(creator: userId1) try await eventColA.addOrUpdateAsync(instance: eventA) // Share with user2 try await StoreCenter.main.setAuthorizedUsersAsync(for: eventA, users: [userId2]) let dataB = try await self.storeCenterB.testSynchronizeOnceAsync() var syncDataB = try SyncData(data: dataB, storeCenter: self.storeCenterB) #expect(syncDataB.shared.count == 1) #expect(eventColB.count == 1) #expect(eventColB.first?.relatedUser == userId1) let tournamentB = Tournament(event: eventA.id, name: "P100") try await tournamentColB.addOrUpdateAsync(instance: tournamentB) let tournaments: [Tournament] = try await self.storeCenterA.service().get() if let tournamentServerCopy = tournaments.first(where: { $0.id == tournamentB.id }) { #expect(tournamentServerCopy.relatedUser == userId2) } else { throw TestError.missingTournament } } /// In this test: /// - first user shares an event with a linked club to the second user /// - first user creates an event with the same club to the second user /// We test that the second event does not have linked data accesses @Test func testDataAccessIssue() async throws { guard let userId1 = self.storeCenterA.userId else { throw TestError.notAuthenticated } guard let userId2 = self.storeCenterB.userId else { throw TestError.notAuthenticated } // Setup let eventColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let clubColA: SyncedCollection = await self.storeCenterA.mainStore.asyncLoadingSynchronizedCollection() let eventColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() let clubColB: SyncedCollection = await self.storeCenterB.mainStore.asyncLoadingSynchronizedCollection() if let dataAccessCollection = self.storeCenterA.dataAccessCollection { try await dataAccessCollection.deleteAsync(contentOfs: Array(dataAccessCollection)) } try await eventColA.deleteAsync(contentOfs: Array(eventColA)) try await clubColA.deleteAsync(contentOfs: Array(clubColA)) let _ = try await self.storeCenterB.testSynchronizeOnceAsync() #expect(eventColB.count == 0) #expect(clubColB.count == 0) // Create let clubA = Club(creator: userId1, name: "Club A", acronym: "CA") try await clubColA.addOrUpdateAsync(instance: clubA) let event1A = Event(creator: userId1, club: clubA.id, name: "event 1") try await eventColA.addOrUpdateAsync(contentOfs: [event1A]) // Share with user2 try await self.storeCenterA.setAuthorizedUsersAsync(for: event1A, users: [userId2]) // try await self.storeCenterA.setAuthorizedUsersAsync(for: event2A, users: [userId2]) var dataB = try await self.storeCenterB.testSynchronizeOnceAsync() var syncDataB = try SyncData(data: dataB, storeCenter: self.storeCenterB) let event2A = Event(creator: userId1, club: clubA.id, name: "event 2") try await eventColA.addOrUpdateAsync(contentOfs: [event2A]) // Remove sharing from user2 // try await self.storeCenterA.setAuthorizedUsersAsync(for: event1A, users: []) // // dataB = try await self.storeCenterB.testSynchronizeOnceAsync() // syncDataB = try SyncData(data: dataB, storeCenter: self.storeCenterB) // #expect(syncDataB.revocations.count == 1) // #expect(syncDataB.revocationParents.count == 1) // // #expect(eventColB.count == 1) // #expect(clubColB.count == 1) // club remains because used in event2A } } extension Tournament { @MainActor public func deleteAndBuildEverythingAsync(preset: PadelTournamentStructurePreset = .manual) async throws { resetBracketPosition() try await deleteStructureAsync() try await deleteGroupStagesAsync() switch preset { case .doubleGroupStage: try await buildGroupStagesAsync() try await addNewGroupStageStepAsync() qualifiedPerGroupStage = 0 groupStageAdditionalQualified = 0 default: try await buildGroupStagesAsync() try await buildBracketAsync() } } public func addNewGroupStageStepAsync() async throws { let lastStep = lastStep() + 1 for i in 0.. 0 { switch groupStageOrderingMode { case .random: try await setGroupStageAsync(randomize: true, keepExistingMatches: keepExistingMatches) case .snake: try await setGroupStageAsync(randomize: false, keepExistingMatches: keepExistingMatches) case .swiss: try await setGroupStageAsync(randomize: true, keepExistingMatches: keepExistingMatches) } } } public func setGroupStageAsync(randomize: Bool, keepExistingMatches: Bool = false) async throws { let groupStages = groupStages() let numberOfBracketsAsInt = groupStages.count // let teamsPerBracket = teamsPerBracket if groupStageCount != numberOfBracketsAsInt { try await deleteGroupStagesAsync() try await buildGroupStagesAsync() } else { // setGroupStageTeams(randomize: randomize) for groupStage in groupStages { try await groupStage.buildMatchesAsync(keepExistingMatches: keepExistingMatches) } } } public func buildBracketAsync(minimalBracketTeamCount: Int? = nil) async throws { guard rounds().isEmpty else { return } let roundCount = RoundRule.numberOfRounds(forTeams: minimalBracketTeamCount ?? bracketTeamCount()) let matchCount = RoundRule.numberOfMatches(forTeams: minimalBracketTeamCount ?? bracketTeamCount()) let rounds = (0.. 1 else { return } guard let tournamentStore else { return } let roundCount = RoundRule.numberOfRounds(forTeams: currentRoundMatchCount) let loserBracketMatchFormat = tournamentObject()?.loserBracketMatchFormat let rounds = (0..