Program.cs


using BlueskySharp.Endpoints;

namespace BlueskySharp.Demo.Demo01
{
    internal class Program
    {
        static void Main(string[] args)
        {
            Console.Write("Your handle  >");
            var handle = Console.ReadLine();

            Console.Write("App Password >");
            var password = Console.ReadLine();

            Console.WriteLine("Logging in ...");
            var service = BlueskyService.LoginWithLoginInfoAsync(
                BlueskyServiceInfo.BskySocial,
                new BlueskyLoginInfo() { Handle = handle, Password = password }).Result;

            Console.WriteLine("Login is success !!");
            Console.WriteLine("Get records ...");

            // レコード一括取得テスト
            var listRecordsResult = service.Repo.ListRecordsAsync(new()
            {
                Repo = handle,
                Collection = "app.bsky.feed.post",
                Limit = 10,
            }).Result;

            foreach (var record in listRecordsResult.Records)
            {
                var recordValue = record.Value;
                Console.WriteLine("{0}: {1}", recordValue.CreatedAt.ToString("yyyy/MM/dd HH:mm:ss"), recordValue.Text.Replace("\n", "\\n"));
            }

            // 単一レコード取得テスト
            var getRecordResult = service.Repo.GetRecordAsync(new()
            {
                Repo = "a32kita.net",
                Collection = "app.bsky.feed.post",
                Rkey = "3lbwng4waus2k",
            }).Result;


            // ログアウトのテスト
            //try
            //{
            //    service.Server.DeleteSessionAsync().Wait();
            //}
            //catch (AggregateException aex)
            //{
            //    var ex = aex.InnerException as BlueskySharpErrorException;
            //    if (ex == null)
            //        throw;

            //    Console.WriteLine("Logout error: {0}, {1}", ex.Error, ex.ErrorMessage);
            //    Console.WriteLine(ex.SourceJson);
            //    Console.ReadLine();
            //}
            //catch (BlueskySharpErrorException ex)
            //{
            //    Console.WriteLine("Logout error: {0}, {1}", ex.Error, ex.ErrorMessage);
            //    Console.WriteLine(ex.SourceJson);
            //    Console.ReadLine();
            //}

            while (true)
            {
                Console.Write("Post message >>");
                var message = Console.ReadLine();
                if (String.IsNullOrEmpty(message))
                    break;

                // 画像のアップロード
                Endpoints.Blob? blob = null;
                using (var testImageStream = File.OpenRead("TestImage.png"))
                {
                    var uploadResult = service.Repo.UploadBlobAsync(new("image/png", testImageStream)).Result;
                    blob = uploadResult?.Blob;
                }

#if true
                // com.atproto.repo.createRecord を使った方法

                var postParam = new Endpoints.Repo.CreateRecordParam()
                {
                    Repo = handle,
                    Collection = "app.bsky.feed.post",
                    Record = new()
                    {
                        Text = "TEST POST: " + message + " (" + DateTimeOffset.Now.ToString() + ")",
                        CreatedAt = DateTimeOffset.Now,
                        Embed = new()
                        {

                            Type = "app.bsky.embed.images",
                            Images =
                            [
                                // Specify image blob
                                new()
                                {
                                    Alt = "Test image",
                                    Image = blob,
                                }
                            ]
                        }
                    }
                };

                var result = service.Repo.CreateRecordAsync(postParam).Result;
#else
                // com.atproto.repo.applyWrites を使った方法

                var writeParam = new Endpoints.Repo.ApplyWritesParam()
                {
                    Repo = handle,
                    Validate = true,
                    Writes =
                    [
                        new()
                        {
                            Type = "com.atproto.repo.applyWrites#create",
                            Collection = "app.bsky.feed.post",
                            Value = new()
                            {
                                Text = "TEST POST (W): " + message + " (" + DateTimeOffset.Now.ToString() + ")",
                                CreatedAt = DateTimeOffset.Now,
                                Embed = new()
                                {
                                    Type = "app.bsky.embed.images",
                                    Images =
                                    [
                                        new()
                                        {
                                            Alt = "Test image",
                                            Image = blob,
                                        }
                                    ]
                                }
                            }
                        }
                    ]
                };

                var result = service.Repo.ApplyWrites(writeParam).Result;
#endif

#if false
                // Markdown 記法の利用
                var md = "こんにちは！これはリンク埋め込みのテストです。\n\nこれは [GitHub へのリンク](https://github.com/) です。見えますか？";
                //md = "hello, this is test post. This is [Link to GitHub](https://github.com/). Can you see?";

                var recordFromMd = Endpoints.Record.FromMarkdownText(md + "\n\n" + Guid.NewGuid());
                recordFromMd.Embed = Endpoints.Embed.FromExternal(new Endpoints.ExternalReference()
                {
                    Title = "Hoge hoge Web site",
                    Description = "hoge foo bar",
                    Uri = new Uri("https://www.a32kita.net")
                });

                var postParam2 = new Endpoints.Repo.CreateRecordParam()
                {
                    Repo = handle,
                    Collection = "app.bsky.feed.post",
                    Record = recordFromMd,
                };

                var result2 = service.Repo.CreateRecordAsync(postParam2).Result;
#endif
            }

            Console.WriteLine("Please press [Enter] key to exit ...");
            Console.ReadLine();
        }
    }
}