var disposables = CompositeDisposable()

// Checking if user is using Kakao Story 
StoryApiClient.rx.isStoryUser()
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ isStoryUser ->
        Log.i(TAG, "Whether to use Kakao Story: $isStoryUser")
    }, { error ->
        Log.e(TAG, "Failed to validate Kakao Story user registration.", error)
    })
    .addTo(disposables)

var disposables = CompositeDisposable()

// Retrieving Kakao Story profile
StoryApiClient.rx.profile()
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ profile ->
        Log.i(TAG, "Succeeded in retrieving Kakao Story profile." +
                "\nNickname: ${profile.nickname}" +
                "\nProfile Image: ${profile.thumbnailUrl}" +
                "\nBirthday: ${profile.birthday}")
    }, { error ->
        Log.e(TAG, "Failed to retrieve Kakao Story profile.", error)
    })
    .addTo(disposables)

var disposables = CompositeDisposable()

// Posting text story
val content = "Posting note from Kakao SDK Sample."

StoryApiClient.rx.postNote(content)
    .retryWhen(
        // Request additional consent for InsufficientScope.
        RxAuthOperations.instance.incrementalAuthorizationRequired(context)
    )
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ storyId ->
        Log.i(TAG, "Succeeded in posting a story. [${storyId}]")
    }, { error ->
        Log.e(TAG, "Failed to post a story.", error)
    })
    .addTo(disposables)

var disposables = CompositeDisposable()

// Posting photo story

// Image file to be uploaded
// This code snippet uses the image file added as a project resource. Use the imge files as your service needs.
val bitmap = BitmapFactory.decodeResource(resources, R.drawable.sample1)
val file = File(context.cacheDir, "sample1.png")
val stream = FileOutputStream(file)
bitmap.compress(Bitmap.CompressFormat.PNG, 100, stream)
stream.close()

// Uploading image
StoryApiClient.rx.upload(listOf(file))
    .flatMap {

        // Posting photo story
        val images = it
        val content = "Posting photo from Kakao SDK Sample."

        StoryApiClient.rx.postPhoto(images, content)
    }
    .retryWhen(
        // Request additional consent for InsufficientScope.
        RxAuthOperations.instance.incrementalAuthorizationRequired(context)
    )
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ storyId ->
        Log.i(TAG, "Succeeded in posting a story. [${storyId}]")
    }, { error ->
        Log.e(TAG, "Failed to post a story.", error)
    })
    .addTo(disposables)

var disposables = CompositeDisposable()

// Posting link story

// Create link info with the specified URL.
StoryApiClient.rx.linkInfo("https://www.kakaocorp.com")
    .flatMap {
        // Posting link story
        val linkInfo = it
        val content = "Posting link from Kakao SDK Sample."
        StoryApiClient.rx.postLink(linkInfo, content)
    }
    .retryWhen(
        // Request additional consent for InsufficientScope.
        RxAuthOperations.instance.incrementalAuthorizationRequired(context)
    )
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ storyId ->
        Log.i(TAG, "Succeeded in posting a story. [${storyId}]")
    }, { error ->
        Log.e(TAG, "Failed to post a story.", error)
    })
    .addTo(disposables)

var disposables = CompositeDisposable()

// Retrieving multiple stories
StoryApiClient.rx.stories()
    .retryWhen(
        // Request additional consent for InsufficientScope.
        RxAuthOperations.instance.incrementalAuthorizationRequired(context)
    )
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ stories ->
        Log.i(TAG, "Succeeded in retrieving Kakao Story. \n$stories")
    }, { error ->
        Log.e(TAG, "Failed to retrieve Kakao Story.", error)
    }).addTo(disposables)

var disposables = CompositeDisposable()

// Retrieving specified story

// This code snippet shows the algorithm for retrieving all stories of the user 
// to figure out story IDs and retrieving the first story by designating the story ID.
StoryApiClient.rx.stories()
    .retryWhen(
        // Request additional consent for InsufficientScope.
        RxAuthOperations.instance.incrementalAuthorizationRequired(context)
    )
    .flatMap { stories ->
        if (stories.isNotEmpty()) {

            // Story ID to be retrieved. 
            val storyId = stories.first().id

            StoryApiClient.rx.story(storyId)
        }
        else {
            Single.error(ClientError(ClientErrorCause.IllegalState, "No stories"))
        }
    }
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ story ->
        Log.i(TAG, "Succeeded in retrieving Kakao Story." +
                "\nID: ${story.id}" +
                "\nMedeia Type: ${story.mediaType}" +
                "\nCreated at: ${story.createdAt}" +
                "\nContent: ${story.content}")
    }, { error ->
        Log.e(TAG, "Failed to retrieve Kakao Story.", error)
    }).addTo(disposables)

var disposables = CompositeDisposable()

// Deleting story

// This code snippet shows the algorithm for retrieving all stories of the user and deleting the first story.
StoryApiClient.rx.stories()
    .retryWhen(
        // Request additional consent for InsufficientScope.
        RxAuthOperations.instance.incrementalAuthorizationRequired(context)
    )
    .flatMapCompletable { stories ->
        if (stories.isNotEmpty()) {

            // Story ID to be deleted. 
            val storyId = stories.first().id

            StoryApiClient.rx.delete(storyId)
        }
        else {
            Completable.error(ClientError(ClientErrorCause.IllegalState, "There is no story :("))
        }
    }
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({
        Log.i(TAG, "Succeeded in deleting story.")
    }, { error ->
        Log.e(TAG, "Failed to delete story.", error)
    }).addTo(disposables)