import os
import zipfile

import rastervision as rv
from rastervision.utils.files import (download_if_needed, make_dir,
                                      load_json_config, save_json_config)
from rastervision.protos.command_pb2 import CommandConfig as CommandConfigMsg
from rastervision.data.raster_source import ChannelOrderError


class Predictor():
    """Class for making predictions based off of a prediction package."""

    def __init__(self,
                 prediction_package_uri,
                 tmp_dir,
                 update_stats=False,
                 channel_order=None):
        """Creates a new Predictor.

        Args:
            prediction_package_uri: The URI of the prediction package to use.
                Can be any type of URI that Raster Vision can read.
            tmp_dir: Temporary directory in which to store files that are used
                by the Predictor. This directory is not cleaned up by this
                class.
            update_stats: Option indicating if any Analyzers should be run on
                the image to be predicted on. Otherwise, the Predictor will use
                the output of Analyzers that are bundled with the predict
                package. This is useful, for instance, if you are predicting
                against imagery that needs to be normalized with a
                StatsAnalyzer, and the color profile of the new imagery is
                significantly different then the imagery the model was trained
                on.
            channel_order: Option for a new channel order to use for the
                imagery being predicted against. If not present, the
                channel_order from the original configuration in the predict
                package will be used.
        """
        self.tmp_dir = tmp_dir
        self.update_stats = update_stats
        self.model_loaded = False

        package_zip_path = download_if_needed(prediction_package_uri, tmp_dir)
        package_dir = os.path.join(tmp_dir, 'package')
        make_dir(package_dir)
        with zipfile.ZipFile(package_zip_path, 'r') as package_zip:
            package_zip.extractall(path=package_dir)

        # Read bundle command config
        bundle_config_path = os.path.join(package_dir, 'bundle_config.json')
        msg = load_json_config(bundle_config_path, CommandConfigMsg())
        bundle_config = msg.bundle_config

        self.task_config = rv.TaskConfig.from_proto(bundle_config.task) \
                                        .load_bundle_files(package_dir)

        self.backend_config = rv.BackendConfig.from_proto(bundle_config.backend) \
                                              .load_bundle_files(package_dir)

        scene_config = rv.SceneConfig.from_proto(bundle_config.scene)
        scene_builder = scene_config.load_bundle_files(package_dir) \
                                    .to_builder() \
                                    .clear_label_source() \
                                    .clear_aois() \
                                    .with_id('PREDICTOR')

        # If the scene does not have a label store, generate a default one.
        if not scene_config.label_store:
            scene_builder = scene_builder.with_task(self.task_config) \
                                         .with_label_store()

        if channel_order:
            raster_source = scene_builder.config['raster_source'] \
                                         .to_builder() \
                                         .with_channel_order(channel_order) \
                                         .build()
            scene_builder = scene_builder.with_raster_source(raster_source)

        self.scene_config = scene_builder.build()

        self.analyzer_configs = []
        if update_stats:
            for analyzer in bundle_config.analyzers:
                a = rv.AnalyzerConfig.from_proto(analyzer) \
                                     .load_bundle_files(package_dir)
                self.analyzer_configs.append(a)

        self.bundle_config = rv.command.CommandConfig \
                                       .from_proto(msg) \
                                       .to_builder() \
                                       .with_task(self.task_config) \
                                       .with_backend(self.backend_config) \
                                       .with_scene(self.scene_config) \
                                       .with_analyzers(self.analyzer_configs) \
                                       .build()

    def load_model(self):
        """Load the model for this Predictor.

        This is useful if you are going to make multiple predictions with the
        model, and want it to be fast on the first prediction.

        Note: This is called implicitly on the first call of 'predict' if it
        hasn't been called already.
        """
        self.backend = self.backend_config.create_backend(self.task_config)
        self.backend.load_model(self.tmp_dir)
        self.task = self.task_config.create_task(self.backend)
        self.analyzers = []
        for analyzer_config in self.analyzer_configs:
            self.analyzers.append(analyzer_config.create_analyzer())
        self.model_loaded = True

    def predict(self, image_uri, label_uri=None, config_uri=None):
        """Generate predictions for the given image.

        Args:
            image_uri: URI of the image to make predictions against.
                This can be any type of URI readable by Raster Vision
                FileSystems.
            label_uri: Optional URI to save labels off into.
            config_uri: Optional URI in which to save the bundle_config,
                which can be useful to client applications for understanding
                how to interpret the labels.

            Returns:
                rastervision.data.labels.Labels containing the predicted labels.
        """
        if not self.model_loaded:
            self.load_model()
        scene_config = self.scene_config.for_prediction(image_uri, label_uri) \
                                        .create_local(self.tmp_dir)

        try:
            scene = scene_config.create_scene(self.task_config, self.tmp_dir)
            # If we are analyzing per scene, run analyzers
            # Analyzers should overwrite files in the tmp_dir
            if self.update_stats:
                for analyzer in self.analyzers:
                    analyzer.process([scene], self.tmp_dir)

                # Reload scene to refresh any new analyzer config
                scene = scene_config.create_scene(self.task_config,
                                                  self.tmp_dir)
        except ChannelOrderError:
            raise ValueError(
                'The predict package is using a channel_order '
                'with channels unavailable in the imagery.\nTo set a new '
                'channel_order that only uses channels available in the '
                'imagery, use the --channel-order option.')

        with scene.activate():
            labels = self.task.predict_scene(scene, self.tmp_dir)
            if label_uri:
                scene.prediction_label_store.save(labels)

        if config_uri:
            msg = self.bundle_config.to_builder() \
                                    .with_scene(scene_config) \
                                    .build() \
                                    .to_proto()
            save_json_config(msg, config_uri)

        return labels

import os
import zipfile

import rastervision as rv
from rastervision.utils.files import (download_if_needed, make_dir,
                                      load_json_config, save_json_config)
from rastervision.protos.command_pb2 import CommandConfig as CommandConfigMsg
from rastervision.data.raster_source import ChannelOrderError


class Predictor():
    """Class for making predictions based off of a prediction package."""

    def __init__(self,
                 prediction_package_uri,
                 tmp_dir,
                 update_stats=False,
                 channel_order=None):
        """Creates a new Predictor.

        Args:
            prediction_package_uri: The URI of the prediction package to use.
                Can be any type of URI that Raster Vision can read.
            tmp_dir: Temporary directory in which to store files that are used
                by the Predictor. This directory is not cleaned up by this
                class.
            update_stats: Option indicating if any Analyzers should be run on
                the image to be predicted on. Otherwise, the Predictor will use
                the output of Analyzers that are bundled with the predict
                package. This is useful, for instance, if you are predicting
                against imagery that needs to be normalized with a
                StatsAnalyzer, and the color profile of the new imagery is
                significantly different then the imagery the model was trained
                on.
            channel_order: Option for a new channel order to use for the
                imagery being predicted against. If not present, the
                channel_order from the original configuration in the predict
                package will be used.
        """
        self.tmp_dir = tmp_dir
        self.update_stats = update_stats
        self.model_loaded = False

        package_zip_path = download_if_needed(prediction_package_uri, tmp_dir)
        package_dir = os.path.join(tmp_dir, 'package')
        make_dir(package_dir)
        with zipfile.ZipFile(package_zip_path, 'r') as package_zip:
            package_zip.extractall(path=package_dir)

        # Read bundle command config
        bundle_config_path = os.path.join(package_dir, 'bundle_config.json')
        msg = load_json_config(bundle_config_path, CommandConfigMsg())
        bundle_config = msg.bundle_config

        self.task_config = rv.TaskConfig.from_proto(bundle_config.task) \
                                        .load_bundle_files(package_dir)

        self.backend_config = rv.BackendConfig.from_proto(bundle_config.backend) \
                                              .load_bundle_files(package_dir)

        scene_config = rv.SceneConfig.from_proto(bundle_config.scene)
        scene_builder = scene_config.load_bundle_files(package_dir) \
                                    .to_builder() \
                                    .clear_label_source() \
                                    .clear_aois() \
                                    .with_id('PREDICTOR')

        # If the scene does not have a label store, generate a default one.
        if not scene_config.label_store:
            scene_builder = scene_builder.with_task(self.task_config) \
                                         .with_label_store()

        if channel_order:
            raster_source = scene_builder.config['raster_source'] \
                                         .to_builder() \
                                         .with_channel_order(channel_order) \
                                         .build()
            scene_builder = scene_builder.with_raster_source(raster_source)

        self.scene_config = scene_builder.build()

        self.analyzer_configs = []
        if update_stats:
            for analyzer in bundle_config.analyzers:
                a = rv.AnalyzerConfig.from_proto(analyzer) \
                                     .load_bundle_files(package_dir)
                self.analyzer_configs.append(a)

        self.bundle_config = rv.command.CommandConfig \
                                       .from_proto(msg) \
                                       .to_builder() \
                                       .with_task(self.task_config) \
                                       .with_backend(self.backend_config) \
                                       .with_scene(self.scene_config) \
                                       .with_analyzers(self.analyzer_configs) \
                                       .build()

    def load_model(self):
        """Load the model for this Predictor.

        This is useful if you are going to make multiple predictions with the
        model, and want it to be fast on the first prediction.

        Note: This is called implicitly on the first call of 'predict' if it
        hasn't been called already.
        """
        self.backend = self.backend_config.create_backend(self.task_config)
        self.backend.load_model(self.tmp_dir)
        self.task = self.task_config.create_task(self.backend)
        self.analyzers = []
        for analyzer_config in self.analyzer_configs:
            self.analyzers.append(analyzer_config.create_analyzer())
        self.model_loaded = True

    def predict(self, image_uri, label_uri=None, config_uri=None):
        """Generate predictions for the given image.

        Args:
            image_uri: URI of the image to make predictions against.
                This can be any type of URI readable by Raster Vision
                FileSystems.
            label_uri: Optional URI to save labels off into.
            config_uri: Optional URI in which to save the bundle_config,
                which can be useful to client applications for understanding
                how to interpret the labels.

            Returns:
                rastervision.data.labels.Labels containing the predicted labels.
        """
        if not self.model_loaded:
            self.load_model()
        scene_config = self.scene_config.for_prediction(image_uri, label_uri) \
                                        .create_local(self.tmp_dir)

        try:
            scene = scene_config.create_scene(self.task_config, self.tmp_dir)
            # If we are analyzing per scene, run analyzers
            # Analyzers should overwrite files in the tmp_dir
            if self.update_stats:
                for analyzer in self.analyzers:
                    analyzer.process([scene], self.tmp_dir)

                # Reload scene to refresh any new analyzer config
                scene = scene_config.create_scene(self.task_config,
                                                  self.tmp_dir)
        except ChannelOrderError:
            raise ValueError(
                'The predict package is using a channel_order '
                'with channels unavailable in the imagery.\nTo set a new '
                'channel_order that only uses channels available in the '
                'imagery, use the --channel-order option.')

        with scene.activate():
            labels = self.task.predict_scene(scene, self.tmp_dir)
            if label_uri:
                scene.prediction_label_store.save(labels)

        if config_uri:
            msg = self.bundle_config.to_builder() \
                                    .with_scene(scene_config) \
                                    .build() \
                                    .to_proto()
            save_json_config(msg, config_uri)

        return labels

Class for making predictions based off of a prediction package. Creates a new Predictor.          Args:             prediction_package_uri: The URI of the prediction package to use.                 Can be any type of URI that Raster Vision can read.             tmp_dir: Temporary directory in which to store files that are used                 by the Predictor. This directory is not cleaned up by this                 class.             update_stats: Option indicating if any Analyzers should be run on                 the image to be predicted on. Otherwise, the Predictor will use                 the output of Analyzers that are bundled with the predict                 package. This is useful, for instance, if you are predicting                 against imagery that needs to be normalized with a                 StatsAnalyzer, and the color profile of the new imagery is                 significantly different then the imagery the model was trained                 on.             channel_order: Option for a new channel order to use for the                 imagery being predicted against. If not present, the                 channel_order from the original configuration in the predict                 package will be used. # Read bundle command config # If the scene does not have a label store, generate a default one. Load the model for this Predictor.          This is useful if you are going to make multiple predictions with the         model, and want it to be fast on the first prediction.          Note: This is called implicitly on the first call of 'predict' if it         hasn't been called already. Generate predictions for the given image.          Args:             image_uri: URI of the image to make predictions against.                 This can be any type of URI readable by Raster Vision                 FileSystems.             label_uri: Optional URI to save labels off into.             config_uri: Optional URI in which to save the bundle_config,                 which can be useful to client applications for understanding                 how to interpret the labels.              Returns:                 rastervision.data.labels.Labels containing the predicted labels. # If we are analyzing per scene, run analyzers # Analyzers should overwrite files in the tmp_dir # Reload scene to refresh any new analyzer config