Add async initializer to main class

Author: MasterJ93

Sources/ATProtoKit/ATProtoKit.swift

@@ -111,6 +111,8 @@ extension ATProtoKitConfiguration {
 ///         try await config.authenticate()
 ///
 ///         print("Access token: \(session.accessToken)")
+///
+///         let atProtoKit = try await ATProtoKit(sessionConfiguration: config)
 ///     } catch {
 ///         print("Error: \(error)")
 ///     }
@@ -167,18 +169,36 @@ public class ATProtoKit: ATProtoKitConfiguration, ATRecordConfiguration {
         self.sessionConfiguration = sessionConfiguration
         self.logger = session?.logger
 
-        // Mark the beginning of registration.
-        // This is to fix a bug from the following issue: https://github.com/MasterJ93/ATProtoKit/issues/75
-        // as well as this issue: https://github.com/MasterJ93/ATProtoKit/issues/102
-        ATRecordTypeRegistry.registrationGroup.enter()
-
         Task { [recordLexicons] in
             if canUseBlueskyRecords && !(ATRecordTypeRegistry.areBlueskyRecordsRegistered) {
                 _ = await ATRecordTypeRegistry.shared.register(blueskyLexiconTypes: recordLexicons)
             }
+        }
+    }
+
+    /// Initializes a new, asyncronous instance of `ATProtoKit`.
+    ///
+    /// This will also handle some of the logging-related setup. The identifier will either be your
+    /// project's `CFBundleIdentifier` or an identifier named
+    /// `com.cjrriley.ATProtoKit`. However, you can manually override this.
+    ///
+    /// If you're using methods such as
+    /// ``ATProtoKit/ATProtoKit/createAccount(email:handle:existingDID:inviteCode:verificationCode:verificationPhone:password:recoveryKey:plcOperation:pdsURL:)``
+    /// or ``ATProtoKit/ATProtoKit/getSession(by:pdsURL:)``, be sure to set
+    /// `canUseBlueskyRecords` to false. While the initializer does check to see if the records
+    /// have been added, it's best not to invoke it, esepcially if you're using ATProtoKit for a
+    /// generic AT Protocol service that doesn't use Bluesky records.
+    ///
+    /// - Parameters:
+    ///   - sessionConfiguration: The authenticated user session within the AT Protocol. Optional.
+    ///   - canUseBlueskyRecords: Indicates whether Bluesky's lexicons should be used.
+    ///   Defaults to `true`.
+    public init(sessionConfiguration: SessionConfiguration? = nil, canUseBlueskyRecords: Bool = true) async {
+        self.sessionConfiguration = sessionConfiguration
+        self.logger = session?.logger
 
-            // Registration complete – signal waiting threads.
-            ATRecordTypeRegistry.registrationGroup.leave()
+        if canUseBlueskyRecords && !(ATRecordTypeRegistry.areBlueskyRecordsRegistered) {
+            _ = await ATRecordTypeRegistry.shared.register(blueskyLexiconTypes: recordLexicons)
         }
     }
 

Sources/ATProtoKit/Models/Common/ATRecordViewProtocol/ATRecordViewProtocolExtensions.swift

@@ -13,7 +13,7 @@ extension AppBskyLexicon.Feed.PostViewDefinition: ATRecordViewProtocol {
         let config = ATProtocolConfiguration(userSession: session, pdsURL: session.pdsURL ?? "https://bsky.social")
         _ = try await config.getSession()
 
-        let atProto = ATProtoKit(sessionConfiguration: config, canUseBlueskyRecords: false)
+        let atProto = await ATProtoKit(sessionConfiguration: config, canUseBlueskyRecords: false)
         let record = try await atProto.getPosts([self.uri])
 
         return record.posts[0]
@@ -30,7 +30,7 @@ extension AppBskyLexicon.Feed.GeneratorViewDefinition: ATRecordViewProtocol {
         let config = ATProtocolConfiguration(userSession: session, pdsURL: session.pdsURL ?? "https://bsky.social")
         _ = try await config.getSession()
 
-        let atProto = ATProtoKit(sessionConfiguration: config, canUseBlueskyRecords: false)
+        let atProto = await ATProtoKit(sessionConfiguration: config, canUseBlueskyRecords: false)
         let record = try await atProto.getFeedGenerator(by: self.feedURI)
 
         return record.view
@@ -43,7 +43,7 @@ extension AppBskyLexicon.Graph.ListViewDefinition: ATRecordViewProtocol {
         let config = ATProtocolConfiguration(userSession: session, pdsURL: session.pdsURL ?? "https://bsky.social")
         _ = try await config.getSession()
 
-        let atProto = ATProtoKit(sessionConfiguration: config, canUseBlueskyRecords: false)
+        let atProto = await ATProtoKit(sessionConfiguration: config, canUseBlueskyRecords: false)
         let record = try await atProto.getList(from: self.uri)
 
         return record.list
@@ -56,7 +56,7 @@ extension AppBskyLexicon.Graph.StarterPackViewDefinition: ATRecordViewProtocol {
         let config = ATProtocolConfiguration(userSession: session, pdsURL: session.pdsURL ?? "https://bsky.social")
         _ = try await config.getSession()
 
-        let atProto = ATProtoKit(sessionConfiguration: config, canUseBlueskyRecords: false)
+        let atProto = await ATProtoKit(sessionConfiguration: config, canUseBlueskyRecords: false)
         let record = try await atProto.getStarterPack(uri: self.uri)
 
         return record.starterPack
@@ -73,7 +73,7 @@ extension AppBskyLexicon.Feed.FeedViewPostDefinition: ATRecordViewProtocol {
         let config = ATProtocolConfiguration(userSession: session, pdsURL: session.pdsURL ?? "https://bsky.social")
         _ = try await config.getSession()
 
-        let atProto = ATProtoKit(sessionConfiguration: config, canUseBlueskyRecords: false)
+        let atProto = await ATProtoKit(sessionConfiguration: config, canUseBlueskyRecords: false)
         let record = try await atProto.getFeed(by: self.post.uri)
 
         return record.feed[0]