var disposables = CompositeDisposable()

// 카카오스토리 사용자 확인하기
StoryApiClient.rx.isStoryUser()
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ isStoryUser ->
        Log.i(TAG, "카카오스토리 가입 여부: $isStoryUser")
    }, { error ->
        Log.e(TAG, "카카스토리 사용자 확인 실패", error)
    })
    .addTo(disposables)

var disposables = CompositeDisposable()

// 카카오스토리 프로필 가져오기
StoryApiClient.rx.profile()
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ profile ->
        Log.i(TAG, "카카오스토리 프로필 가져오기 성공" +
                "\n닉네임: ${profile.nickname}" +
                "\n프로필사진: ${profile.thumbnailUrl}" +
                "\n생일: ${profile.birthday}")
    }, { error ->
        Log.e(TAG, "카카오스토리 프로필 가져오기 실패", error)
    })
    .addTo(disposables)

var disposables = CompositeDisposable()

// 글 스토리 쓰기
val content = "Posting note from Kakao SDK Sample."

StoryApiClient.rx.postNote(content)
    .retryWhen(
        // InsufficientScope 에러에 대해 추가 동의 후 재요청
        RxAuthOperations.instance.incrementalAuthorizationRequired(context)
    )
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ storyId ->
        Log.i(TAG, "스토리 쓰기 성공 [${storyId}]")
    }, { error ->
        Log.e(TAG, "스토리 쓰기 실패", error)
    })
    .addTo(disposables)

var disposables = CompositeDisposable()

// 사진 스토리 쓰기

// 업로드할 사진 파일
// 이 예제에서는 프로젝트 리소스로 추가한 이미지 파일을 사용했습니다.
// 갤러리 등 서비스에 필요한 사진 파일을 준비합니다.
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()

// 사진 업로드
StoryApiClient.rx.upload(listOf(file))
    .flatMap {

        // 사진 스토리 쓰기
        val images = it
        val content = "Posting photo from Kakao SDK Sample."

        StoryApiClient.rx.postPhoto(images, content)
    }
    .retryWhen(
        // InsufficientScope 에러에 대해 추가 동의 후 재요청
        RxAuthOperations.instance.incrementalAuthorizationRequired(context)
    )
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ storyId ->
        Log.i(TAG, "스토리 쓰기 성공 [${storyId}]")
    }, { error ->
        Log.e(TAG, "스토리 쓰기 실패", error)
    })
    .addTo(disposables)

var disposables = CompositeDisposable()

// 링크 스토리 쓰기

// 지정된 URL로 링크 만들기
StoryApiClient.rx.linkInfo("https://www.kakaocorp.com")
    .flatMap {
        // 링크 스토리 쓰기
        val linkInfo = it
        val content = "Posting link from Kakao SDK Sample."
        StoryApiClient.rx.postLink(linkInfo, content)
    }
    .retryWhen(
        // InsufficientScope 에러에 대해 추가 동의 후 재요청
        RxAuthOperations.instance.incrementalAuthorizationRequired(context)
    )
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ storyId ->
        Log.i(TAG, "스토리 쓰기 성공 [${storyId}]")
    }, { error ->
        Log.e(TAG, "스토리 쓰기 실패", error)
    })
    .addTo(disposables)

var disposables = CompositeDisposable()

// 여러 개의 스토리 가져오기
StoryApiClient.rx.stories()
    .retryWhen(
        // InsufficientScope 에러에 대해 추가 동의 후 재요청
        RxAuthOperations.instance.incrementalAuthorizationRequired(context)
    )
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({ stories ->
        Log.i(TAG, "스토리 가져오기 성공 \n$stories")
    }, { error ->
        Log.e(TAG, "스토리 가져오기 실패", error)
    }).addTo(disposables)

var disposables = CompositeDisposable()

// 하나의 스토리 가져오기

// 이 예제에서는 받고자 하는 스토리 아이디를 얻기 위해 전체 목록을 조회하고 첫번째 스토리 아이디를 사용했습니다.
StoryApiClient.rx.stories()
    .retryWhen(
        // InsufficientScope 에러에 대해 추가 동의 후 재요청
        RxAuthOperations.instance.incrementalAuthorizationRequired(context)
    )
    .flatMap { stories ->
        if (stories.isNotEmpty()) {

            // 정보를 원하는 스토리 아이디
            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, "스토리 가져오기 성공" +
                "\n아이디: ${story.id}" +
                "\n미디어 형식: ${story.mediaType}" +
                "\n작성일자: ${story.createdAt}" +
                "\n내용: ${story.content}")
    }, { error ->
        Log.e(TAG, "스토리 가져오기 실패", error)
    }).addTo(disposables)

var disposables = CompositeDisposable()

// 내 스토리 삭제하기

// 이 예제에서는 삭제고자 하는 스토리 아이디를 얻기 위해 전체 목록을 조회하고 첫번째 스토리 아이디를 사용했습니다.
StoryApiClient.rx.stories()
    .retryWhen(
        // InsufficientScope 에러에 대해 추가 동의 후 재요청
        RxAuthOperations.instance.incrementalAuthorizationRequired(context)
    )
    .flatMapCompletable { stories ->
        if (stories.isNotEmpty()) {

            // 삭제를 원하는 스토리 아이디
            val storyId = stories.first().id

            StoryApiClient.rx.delete(storyId)
        }
        else {
            Completable.error(ClientError(ClientErrorCause.IllegalState, "내 스토리가 하나도 없어요 ㅠㅠ"))
        }
    }
    .subscribeOn(Schedulers.io())
    .observeOn(AndroidSchedulers.mainThread())
    .subscribe({
        Log.i(TAG, "스토리 삭제 성공")
    }, { error ->
        Log.e(TAG, "스토리 삭제 실패", error)
    }).addTo(disposables)