/*
 * Copyright (c) 2025 Huawei Device Co., Ltd.
 * Licensed under the Apache License, Version 2.0 (the "License");
 * you may not use this file except in compliance with the License.
 * You may obtain a copy of the License at
 *
 *     http://www.apache.org/licenses/LICENSE-2.0
 *
 * Unless required by applicable law or agreed to in writing, software
 * distributed under the License is distributed on an "AS IS" BASIS,
 * WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied.
 * See the License for the specific language governing permissions and
 * limitations under the License.
 */

import { Logger, ObservedArray, Topic } from '@ohos/utils';
import { TopicNetFunc } from '../service/TopicNetFunc';

const TAG = '[TopicModel]';

export class TopicModel {
  private static instance: TopicModel;
  public totalTopicList: ObservedArray<Topic> = new ObservedArray<Topic>();
  private funNetwork: TopicNetFunc;

  private constructor() {
    this.funNetwork = new TopicNetFunc();
  }

  public static getInstance(): TopicModel {
    if (!TopicModel.instance) {
      TopicModel.instance = new TopicModel();
    }
    return TopicModel.instance;
  }

  getTopics(): Promise<void> {
    return new Promise((resolve: Function, reject: Function) => {
      this.funNetwork.getTopics(AppStorage.get<string>('userId') as string).then((topics: Topic[]) => {
        this.totalTopicList.length = 0;
        topics.forEach((topic: Topic) => {
          this.totalTopicList.push(new Topic(topic));
        })
        resolve();
      }).catch((err: Error) => {
        Logger.error(TAG, `Get topics failed! Error message is ${err}`);
        reject();
      });
    });
  }

  updateFollowedTopics(followedIds: string[]): Promise<void> {
    return new Promise((resolve: Function, reject: Function) => {
      this.funNetwork.editTopicsFollowed(AppStorage.get<string>('userId') as string, followedIds.join(',')).then(() => {
        this.totalTopicList.forEach((topic: Topic) => {
          topic.isFollowed = followedIds.find((id: string) => id === topic.id) ? true : false;
        });
        resolve();
      }).catch((err: Error) => {
        Logger.error(TAG, `Update followed topics failed! Error message is ${err}`);
        reject();
      })
    })
  }
}