mapgen_rivers/erosion.py

import numpy as np
import scipy.ndimage as im
import rivermapper as rm

def advection(dem, dirs, rivers, time, K=1, m=0.5, sea_level=0):
    dirs = dirs.copy()
    dirs[0,:] = 0
    dirs[-1,:] = 0
    dirs[:,0] = 0
    dirs[:,-1] = 0

    adv_time = 1 / (K*rivers**m)
    dem = np.maximum(dem, sea_level)
    dem_new = np.zeros(dem.shape)

    for y in range(dirs.shape[0]):
        for x in range(dirs.shape[1]):
            x0, y0 = x, y
            x1, y1 = x, y
            remaining = time
            while True:
                flow_dir = dirs[y0,x0]
                if flow_dir == 0:
                    remaining = 0
                    break
                elif flow_dir == 1:
                    y1 += 1
                elif flow_dir == 2:
                    x1 += 1
                elif flow_dir == 3:
                    y1 -= 1
                elif flow_dir == 4:
                    x1 -= 1

                if remaining <= adv_time[y0,x0]:
                    break
                remaining -= adv_time[y0,x0]
                x0, y0 = x1, y1

            c = remaining / adv_time[y0,x0]
            dem_new[y,x] = c*dem[y1,x1] + (1-c)*dem[y0,x0]

    return np.minimum(dem, dem_new)

def diffusion(dem, time, d=1):
    radius = d * time**.5
    return im.gaussian_filter(dem, radius, mode='reflect')

class EvolutionModel:
    def __init__(self, dem, K=1, m=0.5, d=1, sea_level=0, flow=False, flex_radius=100):
        self.dem = dem
        #self.bedrock = dem
        self.K = K
        self.m = m
        self.d = d
        self.sea_level = sea_level
        self.flex_radius = flex_radius
        self.define_isostasy()
        if flow:
            self.calculate_flow()
        else:
            self.lakes = dem
            self.dirs = np.zeros(dem.shape, dtype='u1')
            self.rivers = np.zeros(dem.shape, dtype='u4')
            self.flow_uptodate = False

    def calculate_flow(self):
        self.dirs, self.lakes, self.rivers = rm.flow(self.dem)
        self.flow_uptodate = True

    def advection(self, time):
        dem = advection(self.lakes, self.dirs, self.rivers, time, K=self.K, m=self.m, sea_level=self.sea_level)
        self.dem = np.minimum(dem, self.dem)
        self.flow_uptodate = False

    def diffusion(self, time):
        self.dem = diffusion(self.dem, time, d=self.d)
        self.flow_uptodate = False

    def define_isostasy(self):
        self.ref_isostasy = im.gaussian_filter(self.dem, self.flex_radius, mode='reflect')

    def adjust_isostasy(self, rate=1):
        isostasy = im.gaussian_filter(self.dem, self.flex_radius, mode='reflect')
        correction = (self.ref_isostasy - isostasy) * rate
        self.dem = self.dem + correction